com.ververica.cdc.connectors.mysql.source.enumerator

Class MySqlSourceEnumerator

java.lang.Object

com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

@Internal
public class MySqlSourceEnumerator
extends Object
implements org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

A MySQL CDC source enumerator that enumerates receive the split request and assign the split to source readers.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addReader(int subtaskId)
void	addSplitsBack(List<MySqlSplit> splits, int subtaskId)
void	close()
void	handleSourceEvent(int subtaskId, org.apache.flink.api.connector.source.SourceEvent sourceEvent)
void	handleSplitRequest(int subtaskId, String requesterHostname)
void	notifyCheckpointComplete(long checkpointId)
PendingSplitsState	snapshotState(long checkpointId)
void	start()

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

Constructor Detail

MySqlSourceEnumerator

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

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

handleSplitRequest

public void handleSplitRequest(int subtaskId,
                               @Nullable
                               String requesterHostname)

Specified by:

handleSplitRequest in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

addSplitsBack

public void addSplitsBack(List<MySqlSplit> splits,
                          int subtaskId)

Specified by:

addSplitsBack in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

addReader

public void addReader(int subtaskId)

Specified by:

addReader in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

handleSourceEvent

public void handleSourceEvent(int subtaskId,
                              org.apache.flink.api.connector.source.SourceEvent sourceEvent)

Specified by:

handleSourceEvent in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

snapshotState

public PendingSplitsState snapshotState(long checkpointId)

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

notifyCheckpointComplete

public void notifyCheckpointComplete(long checkpointId)

Specified by:

notifyCheckpointComplete in interface org.apache.flink.api.common.state.CheckpointListener

Specified by:

notifyCheckpointComplete in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.api.connector.source.SplitEnumerator<MySqlSplit,PendingSplitsState>