Package 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 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	Description
static final String	PARTITION_TOKEN	The token of the initial partition.

Constructor Summary

Constructors

Constructor	Description
InitialPartition()

Method Summary

Modifier and Type	Method	Description
static boolean	isInitialPartition(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 Details

PARTITION_TOKEN

public static final 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

Constructor Details

InitialPartition

public InitialPartition()

Method Details

isInitialPartition

public static boolean isInitialPartition(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