| CommitWrapper<CommitT> |
The commit message wrapper, which is used to wrapper the different commit messages and unify the
different implementations of CommitWrapper |
| FlinkCommitter<CommT> |
The committer wrapper of SinkCommitter, which is created by Sink.createCommitter(), used to unify the different sink committer implementations
|
| FlinkGlobalCommitter<CommT,GlobalCommT> |
The committer wrapper of SinkAggregatedCommitter, which is created by Sink.createGlobalCommitter(), used to unify the different implementations of SinkAggregatedCommitter
|
| 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 |
|
| FlinkWriterState<StateT> |
|