Uses of Class
com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset

Packages that use BinlogOffset

Package	Description
com.ververica.cdc.connectors.mysql.debezium
com.ververica.cdc.connectors.mysql.debezium.dispatcher
com.ververica.cdc.connectors.mysql.debezium.reader
com.ververica.cdc.connectors.mysql.source.assigners
com.ververica.cdc.connectors.mysql.source.assigners.state
com.ververica.cdc.connectors.mysql.source.events
com.ververica.cdc.connectors.mysql.source.offset
com.ververica.cdc.connectors.mysql.source.split
com.ververica.cdc.connectors.mysql.source.utils

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.debezium

Methods in com.ververica.cdc.connectors.mysql.debezium that return BinlogOffset

Modifier and Type	Method and Description
static BinlogOffset	DebeziumUtils.currentBinlogOffset(io.debezium.jdbc.JdbcConnection jdbc) Fetch current binlog offsets in MySql Server.

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.debezium.dispatcher

Methods in com.ververica.cdc.connectors.mysql.debezium.dispatcher with parameters of type BinlogOffset

Modifier and Type	Method and Description
void	SignalEventDispatcher.dispatchWatermarkEvent(MySqlSplit mySqlSplit, BinlogOffset watermark, SignalEventDispatcher.WatermarkKind watermarkKind)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.debezium.reader

Methods in com.ververica.cdc.connectors.mysql.debezium.reader that return BinlogOffset

Modifier and Type	Method and Description
BinlogOffset	SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl.getHighWatermark()
BinlogOffset	SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl.getLowWatermark()

Methods in com.ververica.cdc.connectors.mysql.debezium.reader with parameters of type BinlogOffset

Modifier and Type	Method and Description
void	SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl.setHighWatermark(BinlogOffset highWatermark)
void	SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl.setLowWatermark(BinlogOffset lowWatermark)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.assigners

Methods in com.ververica.cdc.connectors.mysql.source.assigners that return types with arguments of type BinlogOffset

Modifier and Type	Method and Description
Map<String,BinlogOffset>	MySqlSnapshotSplitAssigner.getSplitFinishedOffsets()

Method parameters in com.ververica.cdc.connectors.mysql.source.assigners with type arguments of type BinlogOffset

Modifier and Type	Method and Description
void	MySqlSnapshotSplitAssigner.onFinishedSplits(Map<String,BinlogOffset> splitFinishedOffsets)
void	MySqlBinlogSplitAssigner.onFinishedSplits(Map<String,BinlogOffset> splitFinishedOffsets)
void	MySqlSplitAssigner.onFinishedSplits(Map<String,BinlogOffset> splitFinishedOffsets) Callback to handle the finished splits with finished binlog offset.
void	MySqlHybridSplitAssigner.onFinishedSplits(Map<String,BinlogOffset> splitFinishedOffsets)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.assigners.state

Methods in com.ververica.cdc.connectors.mysql.source.assigners.state that return types with arguments of type BinlogOffset

Modifier and Type	Method and Description
Map<String,BinlogOffset>	SnapshotPendingSplitsState.getSplitFinishedOffsets()

Constructor parameters in com.ververica.cdc.connectors.mysql.source.assigners.state with type arguments of type BinlogOffset

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)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.events

Methods in com.ververica.cdc.connectors.mysql.source.events that return types with arguments of type BinlogOffset

Modifier and Type	Method and Description
Map<String,BinlogOffset>	FinishedSnapshotSplitsReportEvent.getFinishedOffsets()

Constructor parameters in com.ververica.cdc.connectors.mysql.source.events with type arguments of type BinlogOffset

Constructor and Description
FinishedSnapshotSplitsReportEvent(Map<String,BinlogOffset> finishedOffsets)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.offset

Fields in com.ververica.cdc.connectors.mysql.source.offset declared as BinlogOffset

Modifier and Type	Field and Description
static BinlogOffset	BinlogOffset.INITIAL_OFFSET
static BinlogOffset	BinlogOffset.NO_STOPPING_OFFSET

Methods in com.ververica.cdc.connectors.mysql.source.offset that return BinlogOffset

Modifier and Type	Method and Description
BinlogOffset	BinlogOffsetSerializer.deserialize(byte[] bytes)

Methods in com.ververica.cdc.connectors.mysql.source.offset with parameters of type BinlogOffset

Modifier and Type	Method and Description
int	BinlogOffset.compareTo(BinlogOffset that) This method is inspired by HistoryRecordComparator.
boolean	BinlogOffset.isAfter(BinlogOffset that)
boolean	BinlogOffset.isAtOrAfter(BinlogOffset that)
boolean	BinlogOffset.isAtOrBefore(BinlogOffset that)
boolean	BinlogOffset.isBefore(BinlogOffset that)
byte[]	BinlogOffsetSerializer.serialize(BinlogOffset binlogOffset)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.split

Methods in com.ververica.cdc.connectors.mysql.source.split that return BinlogOffset

Modifier and Type	Method and Description
BinlogOffset	MySqlBinlogSplit.getEndingOffset()
BinlogOffset	MySqlBinlogSplitState.getEndingOffset()
BinlogOffset	MySqlSnapshotSplit.getHighWatermark()
BinlogOffset	MySqlSnapshotSplitState.getHighWatermark()
BinlogOffset	FinishedSnapshotSplitInfo.getHighWatermark()
BinlogOffset	MySqlBinlogSplit.getStartingOffset()
BinlogOffset	MySqlBinlogSplitState.getStartingOffset()

Methods in com.ververica.cdc.connectors.mysql.source.split with parameters of type BinlogOffset

Modifier and Type	Method and Description
void	MySqlBinlogSplitState.setEndingOffset(BinlogOffset endingOffset)
void	MySqlSnapshotSplitState.setHighWatermark(BinlogOffset highWatermark)
void	MySqlBinlogSplitState.setStartingOffset(BinlogOffset startingOffset)

Constructors in com.ververica.cdc.connectors.mysql.source.split with parameters of type BinlogOffset

Constructor and Description
FinishedSnapshotSplitInfo(io.debezium.relational.TableId tableId, String splitId, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark)
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)
MySqlSnapshotSplit(io.debezium.relational.TableId tableId, String splitId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)

Uses of BinlogOffset in com.ververica.cdc.connectors.mysql.source.utils

Methods in com.ververica.cdc.connectors.mysql.source.utils that return BinlogOffset

Modifier and Type	Method and Description
static BinlogOffset	RecordUtils.getBinlogPosition(Map<String,?> offset)
static BinlogOffset	RecordUtils.getBinlogPosition(org.apache.kafka.connect.source.SourceRecord dataRecord)
static BinlogOffset	RecordUtils.getStartingOffsetOfBinlogSplit(List<FinishedSnapshotSplitInfo> finishedSnapshotSplits) Returns the start offset of the binlog split.
static BinlogOffset	RecordUtils.getWatermark(org.apache.kafka.connect.source.SourceRecord watermarkEvent)
static BinlogOffset	SerializerUtils.readBinlogPosition(org.apache.flink.core.memory.DataInputDeserializer in)
static BinlogOffset	SerializerUtils.readBinlogPosition(int offsetVersion, org.apache.flink.core.memory.DataInputDeserializer in)

Methods in com.ververica.cdc.connectors.mysql.source.utils with parameters of type BinlogOffset

Modifier and Type	Method and Description
static void	SerializerUtils.writeBinlogPosition(BinlogOffset offset, org.apache.flink.core.memory.DataOutputSerializer out)