| Modifier and Type | Method and Description |
|---|---|
List<FinishedSnapshotSplitInfo> |
MySqlSnapshotSplitAssigner.getFinishedSplitInfos() |
List<FinishedSnapshotSplitInfo> |
MySqlBinlogSplitAssigner.getFinishedSplitInfos() |
List<FinishedSnapshotSplitInfo> |
MySqlSplitAssigner.getFinishedSplitInfos()
Gets the finished splits information.
|
List<FinishedSnapshotSplitInfo> |
MySqlHybridSplitAssigner.getFinishedSplitInfos() |
| Modifier and Type | Method and Description |
|---|---|
static FinishedSnapshotSplitInfo |
FinishedSnapshotSplitInfo.deserialize(byte[] serialized) |
| Modifier and Type | Method and Description |
|---|---|
List<FinishedSnapshotSplitInfo> |
MySqlBinlogSplit.getFinishedSnapshotSplitInfos() |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
FinishedSnapshotSplitInfo.serialize(FinishedSnapshotSplitInfo splitInfo) |
| Modifier and Type | Method and Description |
|---|---|
static MySqlBinlogSplit |
MySqlBinlogSplit.appendFinishedSplitInfos(MySqlBinlogSplit binlogSplit,
List<FinishedSnapshotSplitInfo> splitInfos) |
| Constructor and Description |
|---|
MySqlBinlogSplit(String splitId,
BinlogOffset startingOffset,
BinlogOffset endingOffset,
List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos,
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas,
int totalFinishedSplitSize) |
MySqlBinlogSplit(String splitId,
BinlogOffset startingOffset,
BinlogOffset endingOffset,
List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos,
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas,
int totalFinishedSplitSize,
boolean isSuspended) |
| Modifier and Type | Method and Description |
|---|---|
static FinishedSnapshotSplitInfo |
RecordUtils.getSnapshotSplitInfo(MySqlSnapshotSplit split,
org.apache.kafka.connect.source.SourceRecord highWatermark)
Return the finished snapshot split information.
|
| Modifier and Type | Method and Description |
|---|---|
static BinlogOffset |
RecordUtils.getStartingOffsetOfBinlogSplit(List<FinishedSnapshotSplitInfo> finishedSnapshotSplits)
Returns the start offset of the binlog split.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.