Uses of Class
com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsState

Packages that use PendingSplitsState

Package	Description
com.ververica.cdc.connectors.mysql.source
com.ververica.cdc.connectors.mysql.source.assigners
com.ververica.cdc.connectors.mysql.source.assigners.state
com.ververica.cdc.connectors.mysql.source.enumerator

Uses of PendingSplitsState in com.ververica.cdc.connectors.mysql.source

Methods in com.ververica.cdc.connectors.mysql.source that return types with arguments of type PendingSplitsState

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>	MySqlSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> enumContext)
org.apache.flink.core.io.SimpleVersionedSerializer<PendingSplitsState>	MySqlSource.getEnumeratorCheckpointSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>	MySqlSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> enumContext, PendingSplitsState checkpoint)

Methods in com.ververica.cdc.connectors.mysql.source with parameters of type PendingSplitsState

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>	MySqlSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> enumContext, PendingSplitsState checkpoint)

Uses of PendingSplitsState in com.ververica.cdc.connectors.mysql.source.assigners

Methods in com.ververica.cdc.connectors.mysql.source.assigners that return PendingSplitsState

Modifier and Type	Method and Description
PendingSplitsState	MySqlBinlogSplitAssigner.snapshotState(long checkpointId)
PendingSplitsState	MySqlSplitAssigner.snapshotState(long checkpointId) Creates a snapshot of the state of this split assigner, to be stored in a checkpoint.
PendingSplitsState	MySqlHybridSplitAssigner.snapshotState(long checkpointId)

Uses of PendingSplitsState in com.ververica.cdc.connectors.mysql.source.assigners.state

Subclasses of PendingSplitsState in com.ververica.cdc.connectors.mysql.source.assigners.state

Modifier and Type	Class and Description
class	BinlogPendingSplitsState A PendingSplitsState for pending binlog splits.
class	HybridPendingSplitsState A PendingSplitsState for pending hybrid (snapshot & binlog) splits.
class	SnapshotPendingSplitsState A PendingSplitsState for pending snapshot splits.

Methods in com.ververica.cdc.connectors.mysql.source.assigners.state that return PendingSplitsState

Modifier and Type	Method and Description
PendingSplitsState	PendingSplitsStateSerializer.deserialize(int version, byte[] serialized)
PendingSplitsState	PendingSplitsStateSerializer.deserializeLegacyPendingSplitsState(byte[] serialized)
PendingSplitsState	PendingSplitsStateSerializer.deserializePendingSplitsState(byte[] serialized)

Methods in com.ververica.cdc.connectors.mysql.source.assigners.state with parameters of type PendingSplitsState

Modifier and Type	Method and Description
byte[]	PendingSplitsStateSerializer.serialize(PendingSplitsState state)

Uses of PendingSplitsState in com.ververica.cdc.connectors.mysql.source.enumerator

Methods in com.ververica.cdc.connectors.mysql.source.enumerator that return PendingSplitsState

Modifier and Type	Method and Description
PendingSplitsState	MySqlSourceEnumerator.snapshotState(long checkpointId)