Class DataStreamV2SinkUtils
- java.lang.Object
-
- org.apache.flink.api.connector.dsv2.DataStreamV2SinkUtils
-
@Experimental public class DataStreamV2SinkUtils extends Object
Utils to create the DataStream V2 supportedSink.
-
-
Constructor Summary
Constructors Constructor Description DataStreamV2SinkUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> org.apache.flink.api.connector.dsv2.Sink<T>wrapSink(Sink<T> sink)Wrap a sink-v2 based sink to a DataStream V2 supported sink.
-
-
-
Method Detail
-
wrapSink
public static <T> org.apache.flink.api.connector.dsv2.Sink<T> wrapSink(Sink<T> sink)
Wrap a sink-v2 based sink to a DataStream V2 supported sink.- Parameters:
sink- The sink-v2 based sink to wrap.- Returns:
- The DataStream V2 supported sink.
-
-