Package org.apache.flink.cdc.connectors.db2.source.offset

Class LsnOffset

java.lang.Object

org.apache.flink.cdc.connectors.base.source.meta.offset.Offset

org.apache.flink.cdc.connectors.db2.source.offset.LsnOffset

All Implemented Interfaces:

Serializable, Comparable<Offset>

public class LsnOffset
extends Offset

A structure describes an offset in a Lsn event.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static LsnOffset	INITIAL_OFFSET
static LsnOffset	NO_STOPPING_OFFSET

Fields inherited from class org.apache.flink.cdc.connectors.base.source.meta.offset.Offset

offset

Constructor Summary

Constructors

Constructor	Description
LsnOffset(io.debezium.connector.db2.Lsn changeLsn)
LsnOffset(io.debezium.connector.db2.Lsn changeLsn, io.debezium.connector.db2.Lsn commitLsn, Long eventSerialNo)

Method Summary

Modifier and Type	Method	Description
int	compareTo(Offset offset)
boolean	equals(Object o)

Methods inherited from class org.apache.flink.cdc.connectors.base.source.meta.offset.Offset

getOffset, hashCode, isAfter, isAtOrAfter, isAtOrBefore, isBefore, longOffsetValue, toString

Methods inherited from class java.lang.Object

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

Field Detail

INITIAL_OFFSET

public static final LsnOffset INITIAL_OFFSET

NO_STOPPING_OFFSET

public static final LsnOffset NO_STOPPING_OFFSET

Constructor Detail

LsnOffset

public LsnOffset(io.debezium.connector.db2.Lsn changeLsn,
                 io.debezium.connector.db2.Lsn commitLsn,
                 Long eventSerialNo)

LsnOffset

public LsnOffset(io.debezium.connector.db2.Lsn changeLsn)

Method Detail

compareTo

public int compareTo(Offset offset)

equals

public boolean equals(Object o)

Overrides:

equals in class Offset