Uses of Class
com.ververica.cdc.connectors.mysql.source.split.MySqlSplit

Packages that use MySqlSplit

Package	Description
com.ververica.cdc.connectors.mysql.debezium.dispatcher
com.ververica.cdc.connectors.mysql.debezium.reader
com.ververica.cdc.connectors.mysql.debezium.task.context
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
com.ververica.cdc.connectors.mysql.source.reader
com.ververica.cdc.connectors.mysql.source.split

Uses of MySqlSplit in com.ververica.cdc.connectors.mysql.debezium.dispatcher

Methods in com.ververica.cdc.connectors.mysql.debezium.dispatcher with parameters of type MySqlSplit

Modifier and Type	Method and Description
void	SignalEventDispatcher.dispatchWatermarkEvent(MySqlSplit mySqlSplit, BinlogOffset watermark, SignalEventDispatcher.WatermarkKind watermarkKind)

Uses of MySqlSplit in com.ververica.cdc.connectors.mysql.debezium.reader

Methods in com.ververica.cdc.connectors.mysql.debezium.reader with parameters of type MySqlSplit

Modifier and Type	Method and Description
void	BinlogSplitReader.submitSplit(MySqlSplit mySqlSplit)
void	SnapshotSplitReader.submitSplit(MySqlSplit mySqlSplit)

Uses of MySqlSplit in com.ververica.cdc.connectors.mysql.debezium.task.context

Methods in com.ververica.cdc.connectors.mysql.debezium.task.context with parameters of type MySqlSplit

Modifier and Type	Method and Description
void	StatefulTaskContext.configure(MySqlSplit mySqlSplit)

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

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

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.api.connector.source.SourceReader<T,MySqlSplit>	MySqlSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.core.io.SimpleVersionedSerializer<MySqlSplit>	MySqlSource.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>	MySqlSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> enumContext, PendingSplitsState checkpoint)

Method parameters in com.ververica.cdc.connectors.mysql.source with type arguments of type MySqlSplit

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.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>	MySqlSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> enumContext, PendingSplitsState checkpoint)

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

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

Modifier and Type	Method and Description
Optional<MySqlSplit>	MySqlSnapshotSplitAssigner.getNext()
Optional<MySqlSplit>	MySqlBinlogSplitAssigner.getNext()
Optional<MySqlSplit>	MySqlSplitAssigner.getNext() Gets the next split.
Optional<MySqlSplit>	MySqlHybridSplitAssigner.getNext()

Method parameters in com.ververica.cdc.connectors.mysql.source.assigners with type arguments of type MySqlSplit

Modifier and Type	Method and Description
void	MySqlSnapshotSplitAssigner.addSplits(Collection<MySqlSplit> splits)
void	MySqlBinlogSplitAssigner.addSplits(Collection<MySqlSplit> splits)
void	MySqlSplitAssigner.addSplits(Collection<MySqlSplit> splits) Adds a set of splits to this assigner.
void	MySqlHybridSplitAssigner.addSplits(Collection<MySqlSplit> splits)

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

Constructor parameters in com.ververica.cdc.connectors.mysql.source.assigners.state with type arguments of type MySqlSplit

Constructor and Description
PendingSplitsStateSerializer(org.apache.flink.core.io.SimpleVersionedSerializer<MySqlSplit> splitSerializer)

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

Method parameters in com.ververica.cdc.connectors.mysql.source.enumerator with type arguments of type MySqlSplit

Modifier and Type	Method and Description
void	MySqlSourceEnumerator.addSplitsBack(List<MySqlSplit> splits, int subtaskId)

Constructor parameters in com.ververica.cdc.connectors.mysql.source.enumerator with type arguments of type MySqlSplit

Constructor and Description
MySqlSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> context, MySqlSourceConfig sourceConfig, MySqlSplitAssigner splitAssigner)

Uses of MySqlSplit in com.ververica.cdc.connectors.mysql.source.reader

Methods in com.ververica.cdc.connectors.mysql.source.reader that return MySqlSplit

Modifier and Type	Method and Description
protected MySqlSplit	MySqlSourceReader.toSplitType(String splitId, MySqlSplitState splitState)

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

Modifier and Type	Method and Description
List<MySqlSplit>	MySqlSourceReader.snapshotState(long checkpointId)

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

Modifier and Type	Method and Description
protected MySqlSplitState	MySqlSourceReader.initializedState(MySqlSplit split)

Method parameters in com.ververica.cdc.connectors.mysql.source.reader with type arguments of type MySqlSplit

Modifier and Type	Method and Description
void	MySqlSourceReader.addSplits(List<MySqlSplit> splits)
void	MySqlSplitReader.handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<MySqlSplit> splitsChanges)

Uses of MySqlSplit in com.ververica.cdc.connectors.mysql.source.split

Subclasses of MySqlSplit in com.ververica.cdc.connectors.mysql.source.split

Modifier and Type	Class and Description
class	MySqlBinlogSplit The split to describe the binlog of MySql table(s).
class	MySqlSnapshotSplit The split to describe a split of a MySql table snapshot.

Fields in com.ververica.cdc.connectors.mysql.source.split declared as MySqlSplit

Modifier and Type	Field and Description
protected MySqlSplit	MySqlSplitState.split

Methods in com.ververica.cdc.connectors.mysql.source.split that return MySqlSplit

Modifier and Type	Method and Description
MySqlSplit	MySqlSplitSerializer.deserialize(int version, byte[] serialized)
MySqlSplit	MySqlSplitSerializer.deserializeSplit(int version, byte[] serialized)
abstract MySqlSplit	MySqlSplitState.toMySqlSplit() Use the current split state to create a new MySqlSplit.

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

Modifier and Type	Method and Description
byte[]	MySqlSplitSerializer.serialize(MySqlSplit split)

Constructors in com.ververica.cdc.connectors.mysql.source.split with parameters of type MySqlSplit

Constructor and Description
MySqlSplitState(MySqlSplit split)