Package org.apache.flink.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<SourceRecords,T,MySqlSplit,MySqlSplitState>

org.apache.flink.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<SourceRecords,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, eofRecordEvaluator, options, splitFetcherManager

Constructor Summary

Constructors

Constructor	Description
MySqlSourceReader(java.util.function.Supplier<MySqlSplitReader> splitReaderSupplier, MySqlRecordEmitter<T> recordEmitter, org.apache.flink.configuration.Configuration config, MySqlSourceReaderContext context, MySqlSourceConfig sourceConfig)

Method Summary

Modifier and Type	Method	Description
void	addSplits(List<MySqlSplit> splits)
Map<String,MySqlSnapshotSplit>	getFinishedUnackedSplits()
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, pauseOrResumeSplits, 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.common.state.CheckpointListener

notifyCheckpointAborted

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

notifyCheckpointComplete

Constructor Detail

MySqlSourceReader

public MySqlSourceReader(java.util.function.Supplier<MySqlSplitReader> splitReaderSupplier,
                         MySqlRecordEmitter<T> 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<SourceRecords,T,MySqlSplit,MySqlSplitState>

initializedState

protected MySqlSplitState initializedState(MySqlSplit split)

Specified by:

initializedState in class org.apache.flink.connector.base.source.reader.SourceReaderBase<SourceRecords,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<SourceRecords,T,MySqlSplit,MySqlSplitState>

onSplitFinished

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

Specified by:

onSplitFinished in class org.apache.flink.connector.base.source.reader.SourceReaderBase<SourceRecords,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<SourceRecords,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<SourceRecords,T,MySqlSplit,MySqlSplitState>

toSplitType

protected MySqlSplit toSplitType(String splitId,
                                 MySqlSplitState splitState)

Specified by:

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

getFinishedUnackedSplits

@VisibleForTesting
public Map<String,MySqlSnapshotSplit> getFinishedUnackedSplits()