Package org.apache.flink.cdc.connectors.base.source.assigner
-
Interface Summary Interface Description SplitAssigner TheSplitAssigneris responsible for deciding what split should be processed. -
Class Summary Class Description HybridSplitAssigner<C extends SourceConfig> Assigner for Hybrid split which contains snapshot splits and stream splits.SnapshotSplitAssigner<C extends SourceConfig> Assigner for snapshot split.StreamSplitAssigner Assigner for stream split. -
Enum Summary Enum Description AssignerStatus The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword.