public class MySqlSplitReader extends Object implements org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>
SplitReader implementation for the MySqlSource.| Constructor and Description |
|---|
MySqlSplitReader(MySqlSourceConfig sourceConfig,
int subtaskId,
MySqlSourceReaderContext context) |
| 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() |
public MySqlSplitReader(MySqlSourceConfig sourceConfig, int subtaskId, MySqlSourceReaderContext context)
public org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord> fetch()
throws IOException
fetch in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>IOExceptionpublic void handleSplitsChanges(org.apache.flink.connector.base.source.reader.splitreader.SplitsChange<MySqlSplit> splitsChanges)
handleSplitsChanges in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>public void wakeUp()
wakeUp in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>public void close()
throws Exception
close in interface org.apache.flink.connector.base.source.reader.splitreader.SplitReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>ExceptionCopyright © 2022 The Apache Software Foundation. All rights reserved.