类概要
| 类 |
说明 |
| CommitWrapper<CommitT> |
The commit message wrapper, which is used to wrapper the different commit messages and unify the
different implementations of CommitWrapper |
| CommitWrapperSerializer<T> |
The serializer wrapper of the commit message serializer, which is created by Sink.getCommittableSerializer(), used to unify the different implementations of Serializer
|
| FlinkCommitter<CommT> |
The committer wrapper of SinkCommitter, which is created by Sink.createCommitter(), used to unify the different sink committer implementations
|
| FlinkCounter |
|
| FlinkGlobalCommitter<CommT,GlobalCommT> |
The committer wrapper of SinkAggregatedCommitter, which is created by Sink.createGlobalCommitter(), used to unify the different implementations of SinkAggregatedCommitter
|
| FlinkJobMetricsSummary |
|
| FlinkJobMetricsSummary.Builder |
|
| FlinkMeter |
|
| FlinkMetricContext |
|
| FlinkRowCollector |
The implementation of Collector for flink engine.
|
| FlinkSimpleVersionedSerializer<T> |
The serializer wrapper of aggregate commit message serializer, which is created by Sink.getGlobalCommittableSerializer(), used to unify the different implementations of Serializer
|
| FlinkSink<InputT,CommT,WriterStateT,GlobalCommT> |
The sink implementation of Sink, the entrypoint of flink sink translation
|
| FlinkSinkWriter<InputT,CommT,WriterStateT> |
The sink writer implementation of SinkWriter, which is created by Sink.createWriter(org.apache.flink.api.connector.sink.Sink.InitContext, java.util.List<WriterStateT>)
|
| FlinkSinkWriterContext |
|
| 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.
|
| FlinkWriterState<StateT> |
|
| FlinkWriterStateSerializer<T> |
The serializer wrapper of writer state serializer, which is created by Sink.getWriterStateSerializer(), used to unify the different implementations of Serializer
|
| 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> |
|