Interface | Description |
---|---|
Sink<T> |
Sink interface for DataStream api v2.
|
Source<T> |
Source interface for DataStream api v2.
|
Class | Description |
---|---|
DataStreamV2SinkUtils |
Utils to create the DataStream V2 supported
Sink . |
DataStreamV2SourceUtils |
Utils to create the DataStream V2 supported
Source . |
FromDataSource<T> |
DataStream v2 source that emit data from pre-provided data.
|
WrappedSink<T> |
A simple
Sink implementation that wrap a sink-v2 based sink. |
WrappedSource<T> |
A simple
Source implementation that wrap a FLIP-27 source. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.