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

Class ResumeTokenUtils

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.source.utils.ResumeTokenUtils

public class ResumeTokenUtils
extends Object

Utility class to decode resumeToken.

Method Summary

Modifier and Type	Method	Description
static org.bson.BsonTimestamp	decodeTimestamp(org.bson.BsonDocument resumeToken)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

decodeTimestamp

public static org.bson.BsonTimestamp decodeTimestamp(org.bson.BsonDocument resumeToken)