com.ververica.cdc.connectors.mysql.source.split

Class MySqlRecords

java.lang.Object

com.ververica.cdc.connectors.mysql.source.split.MySqlRecords

All Implemented Interfaces:

org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>

public final class MySqlRecords
extends Object
implements org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>

An implementation of RecordsWithSplitIds which contains the records of one table split.

Constructor Summary

Constructors

Constructor and Description
MySqlRecords(String splitId, Iterator recordsForSplit, Set<String> finishedSnapshotSplits)

Method Summary

Modifier and Type	Method and Description
Set<String>	finishedSplits()
static MySqlRecords	forFinishedSplit(String splitId)
static MySqlRecords	forRecords(String splitId, Iterator<org.apache.kafka.connect.source.SourceRecord> recordsForSplit)
org.apache.kafka.connect.source.SourceRecord	nextRecordFromSplit()
String	nextSplit()

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.connector.base.source.reader.RecordsWithSplitIds

recycle

Constructor Detail

MySqlRecords

public MySqlRecords(@Nullable
                    String splitId,
                    @Nullable
                    Iterator recordsForSplit,
                    Set<String> finishedSnapshotSplits)

Method Detail

nextSplit

@Nullable
public String nextSplit()

Specified by:

nextSplit in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>

nextRecordFromSplit

@Nullable
public org.apache.kafka.connect.source.SourceRecord nextRecordFromSplit()

Specified by:

nextRecordFromSplit in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>

finishedSplits

public Set<String> finishedSplits()

Specified by:

finishedSplits in interface org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<org.apache.kafka.connect.source.SourceRecord>

forRecords

public static MySqlRecords forRecords(String splitId,
                                      Iterator<org.apache.kafka.connect.source.SourceRecord> recordsForSplit)

forFinishedSplit

public static MySqlRecords forFinishedSplit(String splitId)