com.ververica.cdc.connectors.mysql.source.reader

Class MySqlSourceReader<T>

java.lang.Object

org.apache.flink.connector.base.source.reader.SourceReaderBase<E,T,SplitT,SplitStateT>

org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader<T>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<T,MySqlSplit>

public class MySqlSourceReader<T>
extends org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

The source reader for MySQL source splits.

Field Summary

Fields inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

config, context, options, recordEmitter, splitFetcherManager

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	addSplits(List<MySqlSplit> splits)
void	handleSourceEvents(org.apache.flink.api.connector.source.SourceEvent sourceEvent)
protected MySqlSplitState	initializedState(MySqlSplit split)
protected void	onSplitFinished(Map<String,MySqlSplitState> finishedSplitIds)
List<MySqlSplit>	snapshotState(long checkpointId)
void	start()
protected MySqlSplit	toSplitType(String splitId, MySqlSplitState splitState)

Methods inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

close, getNumberOfCurrentlyAssignedSplits, isAvailable, notifyNoMoreSplits, pollNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

notifyCheckpointComplete

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

MySqlSourceReader

public 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)

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<T,MySqlSplit>

Overrides:

start in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

initializedState

protected MySqlSplitState initializedState(MySqlSplit split)

Specified by:

initializedState in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

snapshotState

public List<MySqlSplit> snapshotState(long checkpointId)

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SourceReader<T,MySqlSplit>

Overrides:

snapshotState in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

onSplitFinished

protected void onSplitFinished(Map<String,MySqlSplitState> finishedSplitIds)

Specified by:

onSplitFinished in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

addSplits

public void addSplits(List<MySqlSplit> splits)

Specified by:

addSplits in interface org.apache.flink.api.connector.source.SourceReader<T,MySqlSplit>

Overrides:

addSplits in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

handleSourceEvents

public void handleSourceEvents(org.apache.flink.api.connector.source.SourceEvent sourceEvent)

Specified by:

handleSourceEvents in interface org.apache.flink.api.connector.source.SourceReader<T,MySqlSplit>

Overrides:

handleSourceEvents in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>

toSplitType

protected MySqlSplit toSplitType(String splitId,
                                 MySqlSplitState splitState)

Specified by:

toSplitType in class org.apache.flink.connector.base.source.reader.SourceReaderBase<org.apache.kafka.connect.source.SourceRecord,T,MySqlSplit,MySqlSplitState>