Package org.apache.flink.api.connector.dsv2
-
Interface Summary Interface Description Sink<T> Sink interface for DataStream api v2.Source<T> Source interface for DataStream api v2. -
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 simpleSink
implementation that wrap a sink-v2 based sink.WrappedSource<T> A simpleSource
implementation that wrap a FLIP-27 source.