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

Packages that use MySqlSplitState

Package	Description
com.ververica.cdc.connectors.mysql.source.reader
com.ververica.cdc.connectors.mysql.source.split

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

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

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

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

Modifier and Type	Method and Description
void	MySqlRecordEmitter.emitRecord(org.apache.kafka.connect.source.SourceRecord element, org.apache.flink.api.connector.source.SourceOutput<T> output, MySqlSplitState splitState)
protected MySqlSplit	MySqlSourceReader.toSplitType(String splitId, MySqlSplitState splitState)

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

Modifier and Type	Method and Description
protected void	MySqlSourceReader.onSplitFinished(Map<String,MySqlSplitState> finishedSplitIds)

Constructor parameters in com.ververica.cdc.connectors.mysql.source.reader with type arguments of type MySqlSplitState

Constructor and Description

MySqlSourceReader(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>> elementQueue, java.util.function.Supplier<MySqlSplitReader> splitReaderSupplier, org.apache.flink.connector.base.source.reader.RecordEmitter<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplitState> recordEmitter, org.apache.flink.configuration.Configuration config, MySqlSourceReaderContext context, MySqlSourceConfig sourceConfig)

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

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

Modifier and Type	Class and Description
class	MySqlBinlogSplitState The state of split to describe the binlog of MySql table(s).
class	MySqlSnapshotSplitState The state of split to describe the binlog of MySql table(s).