org.apache.beam.sdk.io.gcp.spanner.changestreams.model

Class InitialPartition

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.changestreams.model.InitialPartition

public class InitialPartition
extends java.lang.Object

Utility class to determine initial partition constants and methods.

The initial partition has the artificial token defined by PARTITION_TOKEN and it has no parent tokens.

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.HashSet<java.lang.String>	PARENT_TOKENS The empty set representing the initial partition parent tokens.
static java.lang.String	PARTITION_TOKEN The token of the initial partition.

Constructor Summary

Constructors

Constructor and Description
InitialPartition()

Method Summary

Modifier and Type	Method and Description
static boolean	isInitialPartition(java.lang.String partitionToken) Verifies if the given partition token is the initial partition.

Methods inherited from class java.lang.Object

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

Field Detail

PARTITION_TOKEN

public static final java.lang.String PARTITION_TOKEN

The token of the initial partition. This is an artificial token for the Connector and it is not recognised by Cloud Spanner.

See Also:

Constant Field Values

PARENT_TOKENS

public static final java.util.HashSet<java.lang.String> PARENT_TOKENS

The empty set representing the initial partition parent tokens.

Constructor Detail

InitialPartition

public InitialPartition()

Method Detail

isInitialPartition

public static boolean isInitialPartition(java.lang.String partitionToken)

Verifies if the given partition token is the initial partition.

Parameters:

partitionToken - the partition token to be checked

Returns:

true if the given token is the initial partition, and false otherwise