| FlinkRowCollector |
The implementation of Collector for flink engine.
|
| FlinkSource<SplitT extends org.apache.seatunnel.api.source.SourceSplit,EnumStateT extends Serializable> |
The source implementation of Source, used for proxy all SeaTunnelSource in flink.
|
| FlinkSourceEnumerator<SplitT extends org.apache.seatunnel.api.source.SourceSplit,EnumStateT> |
The implementation of SplitEnumerator, used for proxy all SourceSplitEnumerator
in flink.
|
| FlinkSourceReader<SplitT extends org.apache.seatunnel.api.source.SourceSplit> |
The implementation of SourceReader, used for proxy all SourceReader in flink.
|
| FlinkSourceReaderContext |
The implementation of SourceReader.Context for flink
engine.
|
| FlinkSourceSplitEnumeratorContext<SplitT extends org.apache.seatunnel.api.source.SourceSplit> |
The implementation of SourceSplitEnumerator.Context for
flink engine.
|
| NoMoreElementEvent |
This event represents that there is no more data to read, the execution process is as follows:
|
| SourceEventWrapper |
The SourceEvent wrapper, used for proxy all seatunnel
user-defined source event in flink source.
|
| SplitWrapper<T extends org.apache.seatunnel.api.source.SourceSplit> |
The SourceSplit wrapper, used for proxy all seatunnel
user-defined source split in flink engine.
|
| SplitWrapperSerializer<SplitT extends org.apache.seatunnel.api.source.SourceSplit> |
|