Package org.apache.flink.api.connector.dsv2
-
Class Summary Class Description DataStreamV2SinkUtils Utils to create the DataStream V2 supportedSink.DataStreamV2SourceUtils Utils to create the DataStream V2 supportedSource.FromDataSource<T> DataStream v2 source that emit data from pre-provided data.WrappedSink<T> A simpleSinkimplementation that wrap a sink-v2 based sink.WrappedSource<T> A simpleSourceimplementation that wrap a FLIP-27 source.