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

Class ChangeStreamOffset

java.lang.Object

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

org.apache.flink.cdc.connectors.mongodb.source.offset.ChangeStreamOffset

All Implemented Interfaces:

Serializable, Comparable<Offset>

public class ChangeStreamOffset
extends Offset

A structure describes a fine grained offset in a change log event including resumeToken and clusterTime.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static ChangeStreamOffset	NO_STOPPING_OFFSET
static String	RESUME_TOKEN_FIELD
static String	TIMESTAMP_FIELD

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

offset

Constructor Summary

Constructors

Constructor	Description
ChangeStreamOffset(Map<String,String> offset)
ChangeStreamOffset(org.bson.BsonDocument resumeToken)
ChangeStreamOffset(org.bson.BsonTimestamp timestamp)

Method Summary

Modifier and Type	Method	Description
int	compareTo(Offset offset)
boolean	equals(Object o)
org.bson.BsonDocument	getResumeToken()
org.bson.BsonTimestamp	getTimestamp()
void	updatePosition(org.bson.BsonDocument resumeToken)

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

TIMESTAMP_FIELD

public static final String TIMESTAMP_FIELD

See Also:

Constant Field Values

RESUME_TOKEN_FIELD

public static final String RESUME_TOKEN_FIELD

See Also:

Constant Field Values

NO_STOPPING_OFFSET

public static final ChangeStreamOffset NO_STOPPING_OFFSET

Constructor Detail

ChangeStreamOffset

public ChangeStreamOffset(Map<String,String> offset)

ChangeStreamOffset

public ChangeStreamOffset(org.bson.BsonDocument resumeToken)

ChangeStreamOffset

public ChangeStreamOffset(org.bson.BsonTimestamp timestamp)

Method Detail

updatePosition

public void updatePosition(org.bson.BsonDocument resumeToken)

getResumeToken

@Nullable
public org.bson.BsonDocument getResumeToken()

getTimestamp

public org.bson.BsonTimestamp getTimestamp()

equals

public boolean equals(Object o)

Overrides:

equals in class Offset

compareTo

public int compareTo(Offset offset)