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

Class ChunkUtils

java.lang.Object

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

public class ChunkUtils
extends Object

Utilities to split chunks of collection.

Method Summary

Modifier and Type	Method	Description
static Object[]	boundOfId(org.bson.BsonValue bound)
static Object[]	maxUpperBoundOfId()
static Object[]	minLowerBoundOfId()

Methods inherited from class java.lang.Object

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

Method Detail

boundOfId

public static Object[] boundOfId(org.bson.BsonValue bound)

minLowerBoundOfId

public static Object[] minLowerBoundOfId()

maxUpperBoundOfId

public static Object[] maxUpperBoundOfId()