Class DataStreamV2SinkUtils


  • @Experimental
    public class DataStreamV2SinkUtils
    extends Object
    Utils to create the DataStream V2 supported Sink.
    • Constructor Detail

      • DataStreamV2SinkUtils

        public DataStreamV2SinkUtils()
    • 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.