Uses of Package
org.apache.flink.cdc.connectors.base.source.assigner
-
Classes in org.apache.flink.cdc.connectors.base.source.assigner used by org.apache.flink.cdc.connectors.base.source.assigner 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.SplitAssigner TheSplitAssigneris responsible for deciding what split should be processed. -
Classes in org.apache.flink.cdc.connectors.base.source.assigner used by org.apache.flink.cdc.connectors.base.source.assigner.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.base.source.assigner used by org.apache.flink.cdc.connectors.base.source.enumerator Class Description SplitAssigner TheSplitAssigneris responsible for deciding what split should be processed. -
Classes in org.apache.flink.cdc.connectors.base.source.assigner used by org.apache.flink.cdc.connectors.postgres.source.enumerator Class Description SplitAssigner TheSplitAssigneris responsible for deciding what split should be processed.