public class MySqlBinlogSplitState extends MySqlSplitState
split| Constructor and Description |
|---|
MySqlBinlogSplitState(MySqlBinlogSplit split) |
| Modifier and Type | Method and Description |
|---|---|
BinlogOffset |
getEndingOffset() |
BinlogOffset |
getStartingOffset() |
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> |
getTableSchemas() |
void |
recordSchema(io.debezium.relational.TableId tableId,
io.debezium.relational.history.TableChanges.TableChange latestTableChange) |
void |
setEndingOffset(BinlogOffset endingOffset) |
void |
setStartingOffset(BinlogOffset startingOffset) |
MySqlBinlogSplit |
toMySqlSplit()
Use the current split state to create a new MySqlSplit.
|
String |
toString() |
asBinlogSplitState, asSnapshotSplitState, isBinlogSplitState, isSnapshotSplitStatepublic MySqlBinlogSplitState(MySqlBinlogSplit split)
@Nullable public BinlogOffset getStartingOffset()
public void setStartingOffset(@Nullable BinlogOffset startingOffset)
@Nullable public BinlogOffset getEndingOffset()
public void setEndingOffset(@Nullable BinlogOffset endingOffset)
public Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> getTableSchemas()
public void recordSchema(io.debezium.relational.TableId tableId,
io.debezium.relational.history.TableChanges.TableChange latestTableChange)
public MySqlBinlogSplit toMySqlSplit()
MySqlSplitStatetoMySqlSplit in class MySqlSplitStateCopyright © 2022 The Apache Software Foundation. All rights reserved.