com.ververica.cdc.connectors.mysql.source.assigners.state

Class SnapshotPendingSplitsState

java.lang.Object

com.ververica.cdc.connectors.mysql.source.assigners.state.PendingSplitsState

com.ververica.cdc.connectors.mysql.source.assigners.state.SnapshotPendingSplitsState

public class SnapshotPendingSplitsState
extends PendingSplitsState

A PendingSplitsState for pending snapshot splits.

Constructor Summary

Constructors

Constructor and Description
SnapshotPendingSplitsState(List<io.debezium.relational.TableId> alreadyProcessedTables, List<MySqlSnapshotSplit> remainingSplits, Map<String,MySqlSnapshotSplit> assignedSplits, Map<String,BinlogOffset> splitFinishedOffsets, AssignerStatus assignerStatus, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive, boolean isRemainingTablesCheckpointed)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
List<io.debezium.relational.TableId>	getAlreadyProcessedTables()
Map<String,MySqlSnapshotSplit>	getAssignedSplits()
List<MySqlSnapshotSplit>	getRemainingSplits()
List<io.debezium.relational.TableId>	getRemainingTables()
AssignerStatus	getSnapshotAssignerStatus()
Map<String,BinlogOffset>	getSplitFinishedOffsets()
int	hashCode()
boolean	isRemainingTablesCheckpointed()
boolean	isTableIdCaseSensitive()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SnapshotPendingSplitsState

public SnapshotPendingSplitsState(List<io.debezium.relational.TableId> alreadyProcessedTables,
                                  List<MySqlSnapshotSplit> remainingSplits,
                                  Map<String,MySqlSnapshotSplit> assignedSplits,
                                  Map<String,BinlogOffset> splitFinishedOffsets,
                                  AssignerStatus assignerStatus,
                                  List<io.debezium.relational.TableId> remainingTables,
                                  boolean isTableIdCaseSensitive,
                                  boolean isRemainingTablesCheckpointed)

Method Detail

getAlreadyProcessedTables

public List<io.debezium.relational.TableId> getAlreadyProcessedTables()

getRemainingSplits

public List<MySqlSnapshotSplit> getRemainingSplits()

getAssignedSplits

public Map<String,MySqlSnapshotSplit> getAssignedSplits()

getSplitFinishedOffsets

public Map<String,BinlogOffset> getSplitFinishedOffsets()

getSnapshotAssignerStatus

public AssignerStatus getSnapshotAssignerStatus()

getRemainingTables

public List<io.debezium.relational.TableId> getRemainingTables()

isTableIdCaseSensitive

public boolean isTableIdCaseSensitive()

isRemainingTablesCheckpointed

public boolean isRemainingTablesCheckpointed()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object