Package org.apache.flink.cdc.connectors.mysql.source.assigners
-
Interface Summary Interface Description ChunkSplitter TheChunkSplitter's task is to split table into a set of chunks or called splits (i.e.MySqlSplitAssigner TheMySqlSplitAssigneris responsible for deciding what split should be processed. -
Class Summary Class Description MySqlBinlogSplitAssigner AMySqlSplitAssignerwhich only read binlog from current binlog position.MySqlChunkSplitter TheChunkSplitterimplementation for MySQL.MySqlHybridSplitAssigner AMySqlSplitAssignerthat splits tables into small chunk splits based on primary key range and chunk size and also continue with a binlog split.MySqlSnapshotSplitAssigner AMySqlSplitAssignerthat splits tables into small chunk splits based on primary key range and chunk size. -
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.