com.ververica.cdc.connectors.mysql.source.offset

Class BinlogOffset

java.lang.Object

com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset

All Implemented Interfaces:

Serializable, Comparable<BinlogOffset>

public class BinlogOffset
extends Object
implements Comparable<BinlogOffset>, Serializable

A structure describes a fine grained offset in a binlog event including binlog position and gtid set etc.

This structure can also be used to deal the binlog event in transaction, a transaction may contains multiple change events, and each change event may contain multiple rows. When restart from a specific BinlogOffset, we need to skip the processed change events and the processed rows.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	BINLOG_FILENAME_OFFSET_KEY
static String	BINLOG_POSITION_OFFSET_KEY
static String	EVENTS_TO_SKIP_OFFSET_KEY
static String	GTID_SET_KEY
static BinlogOffset	INITIAL_OFFSET
static BinlogOffset	NO_STOPPING_OFFSET
static String	ROWS_TO_SKIP_OFFSET_KEY
static String	SERVER_ID_KEY
static String	TIMESTAMP_KEY

Constructor Summary

Constructors

Constructor and Description
BinlogOffset(Map<String,String> offset)
BinlogOffset(String filename, long position)
BinlogOffset(String filename, long position, long restartSkipEvents, long restartSkipRows, long binlogEpochSecs, String restartGtidSet, Integer serverId)

Method Summary

Modifier and Type	Method and Description
int	compareTo(BinlogOffset that) This method is inspired by HistoryRecordComparator.
boolean	equals(Object o)
String	getFilename()
String	getGtidSet()
Map<String,String>	getOffset()
long	getPosition()
long	getRestartSkipEvents()
long	getRestartSkipRows()
Long	getServerId()
long	getTimestamp()
int	hashCode()
boolean	isAfter(BinlogOffset that)
boolean	isAtOrAfter(BinlogOffset that)
boolean	isAtOrBefore(BinlogOffset that)
boolean	isBefore(BinlogOffset that)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

BINLOG_FILENAME_OFFSET_KEY

public static final String BINLOG_FILENAME_OFFSET_KEY

See Also:

Constant Field Values

BINLOG_POSITION_OFFSET_KEY

public static final String BINLOG_POSITION_OFFSET_KEY

See Also:

Constant Field Values

EVENTS_TO_SKIP_OFFSET_KEY

public static final String EVENTS_TO_SKIP_OFFSET_KEY

See Also:

Constant Field Values

ROWS_TO_SKIP_OFFSET_KEY

public static final String ROWS_TO_SKIP_OFFSET_KEY

See Also:

Constant Field Values

GTID_SET_KEY

public static final String GTID_SET_KEY

See Also:

Constant Field Values

TIMESTAMP_KEY

public static final String TIMESTAMP_KEY

See Also:

Constant Field Values

SERVER_ID_KEY

public static final String SERVER_ID_KEY

See Also:

Constant Field Values

INITIAL_OFFSET

public static final BinlogOffset INITIAL_OFFSET

NO_STOPPING_OFFSET

public static final BinlogOffset NO_STOPPING_OFFSET

Constructor Detail

BinlogOffset

public BinlogOffset(Map<String,String> offset)

BinlogOffset

public BinlogOffset(String filename,
                    long position)

BinlogOffset

public BinlogOffset(String filename,
                    long position,
                    long restartSkipEvents,
                    long restartSkipRows,
                    long binlogEpochSecs,
                    @Nullable
                    String restartGtidSet,
                    @Nullable
                    Integer serverId)

Method Detail

getOffset

public Map<String,String> getOffset()

getFilename

public String getFilename()

getPosition

public long getPosition()

getRestartSkipEvents

public long getRestartSkipEvents()

getRestartSkipRows

public long getRestartSkipRows()

getGtidSet

public String getGtidSet()

getTimestamp

public long getTimestamp()

getServerId

public Long getServerId()

compareTo

public int compareTo(BinlogOffset that)

This method is inspired by HistoryRecordComparator.

Specified by:

compareTo in interface Comparable<BinlogOffset>

isAtOrBefore

public boolean isAtOrBefore(BinlogOffset that)

isBefore

public boolean isBefore(BinlogOffset that)

isAtOrAfter

public boolean isAtOrAfter(BinlogOffset that)

isAfter

public boolean isAfter(BinlogOffset that)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object