com.ververica.cdc.connectors.mysql.debezium.reader

Class SnapshotSplitReader

java.lang.Object

com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader

All Implemented Interfaces:

DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

public class SnapshotSplitReader
extends Object
implements DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

A snapshot reader that reads data from Table in split level, the split is assigned by primary key range.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl The ChangeEventSource.ChangeEventSourceContext implementation for bounded binlog task of a snapshot split task.
class	SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl ChangeEventSource.ChangeEventSourceContext implementation that keeps low/high watermark for each MySqlSnapshotSplit.

Field Summary

Fields

Modifier and Type	Field and Description
AtomicBoolean	hasNextElement
AtomicBoolean	reachEnd

Constructor Summary

Constructors

Constructor and Description
SnapshotSplitReader(StatefulTaskContext statefulTaskContext, int subtaskId)

Method Summary

Modifier and Type	Method and Description
void	close() Close the reader and releases all resources.
boolean	isFinished() Return the current split of the reader is finished or not.
Iterator<org.apache.kafka.connect.source.SourceRecord>	pollSplitRecords() Reads records from MySQL.
void	submitSplit(MySqlSplit mySqlSplit) Add to split to read, this should call only the when reader is idle.

Methods inherited from class java.lang.Object

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

Field Detail

hasNextElement

public AtomicBoolean hasNextElement

reachEnd

public AtomicBoolean reachEnd

Constructor Detail

SnapshotSplitReader

public SnapshotSplitReader(StatefulTaskContext statefulTaskContext,
                           int subtaskId)

Method Detail

submitSplit

public void submitSplit(MySqlSplit mySqlSplit)

Description copied from interface: DebeziumReader

Add to split to read, this should call only the when reader is idle.

Specified by:

submitSplit in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

isFinished

public boolean isFinished()

Description copied from interface: DebeziumReader

Return the current split of the reader is finished or not.

Specified by:

isFinished in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

pollSplitRecords

@Nullable
public Iterator<org.apache.kafka.connect.source.SourceRecord> pollSplitRecords()
                                                                                  throws InterruptedException

Description copied from interface: DebeziumReader

Reads records from MySQL. The method should return null when reaching the end of the split, the empty Iterator will be returned if the data of split is on pulling.

Specified by:

pollSplitRecords in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>

Throws:

InterruptedException

close

public void close()

Description copied from interface: DebeziumReader

Close the reader and releases all resources.

Specified by:

close in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>