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

Class MySqlSplitReader

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

public class MySqlSplitReader
extends Object
implements org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

The SplitReader implementation for the MySqlSource.

Constructor Summary

Constructors

Constructor and Description
MySqlSplitReader(MySqlSourceConfig sourceConfig, int subtaskId, MySqlSourceReaderContext context)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>	fetch()
void	handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<MySqlSplit> splitsChanges)
void	wakeUp()

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlSplitReader

public MySqlSplitReader(MySqlSourceConfig sourceConfig,
                        int subtaskId,
                        MySqlSourceReaderContext context)

Method Detail

fetch

public org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord> fetch()
                                                                                                                      throws IOException

Specified by:

fetch in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

Throws:

IOException

handleSplitsChanges

public void handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<MySqlSplit> splitsChanges)

Specified by:

handleSplitsChanges in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

wakeUp

public void wakeUp()

Specified by:

wakeUp in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

Throws:

Exception