Uses of Package
org.apache.flink.cdc.connectors.mysql.source.assigners
-
Classes in org.apache.flink.cdc.connectors.mysql.source.assigners used by org.apache.flink.cdc.connectors.mysql.source.assigners Class 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.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. -
Classes in org.apache.flink.cdc.connectors.mysql.source.assigners used by org.apache.flink.cdc.connectors.mysql.source.assigners.state Class 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. -
Classes in org.apache.flink.cdc.connectors.mysql.source.assigners used by org.apache.flink.cdc.connectors.mysql.source.enumerator Class Description MySqlSplitAssigner TheMySqlSplitAssigneris responsible for deciding what split should be processed.