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

Class ChangeStreamsConstants

java.lang.Object

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

public class ChangeStreamsConstants
extends java.lang.Object

Single place for defining the constants used in the Spanner.readChangeStreams() connector.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_CHANGE_STREAM_NAME The default change stream name for a change stream query is the empty String.
static com.google.cloud.Timestamp	DEFAULT_INCLUSIVE_END_AT The default end timestamp for a change stream query is MAX_INCLUSIVE_END_AT.
static com.google.cloud.Timestamp	DEFAULT_INCLUSIVE_START_AT The default start timestamp for a change stream query is Timestamp.MIN_VALUE.
static com.google.cloud.spanner.Options.RpcPriority	DEFAULT_RPC_PRIORITY The default priority for a change stream query is Options.RpcPriority.HIGH.
static com.google.cloud.Timestamp	MAX_INCLUSIVE_END_AT Represents the max end at that can be specified for a change stream.
static PartitionMetadata	SAMPLE_PARTITION We use a bogus partition here to estimate the average size of a partition metadata record.
static int	THROUGHPUT_WINDOW_SECONDS The sliding window size in seconds for throughput reporting.

Constructor Summary

Constructors

Constructor and Description
ChangeStreamsConstants()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

MAX_INCLUSIVE_END_AT

public static final com.google.cloud.Timestamp MAX_INCLUSIVE_END_AT

Represents the max end at that can be specified for a change stream.

DEFAULT_CHANGE_STREAM_NAME

public static final java.lang.String DEFAULT_CHANGE_STREAM_NAME

The default change stream name for a change stream query is the empty String.

See Also:

Constant Field Values

DEFAULT_INCLUSIVE_START_AT

public static final com.google.cloud.Timestamp DEFAULT_INCLUSIVE_START_AT

The default start timestamp for a change stream query is Timestamp.MIN_VALUE.

DEFAULT_INCLUSIVE_END_AT

public static final com.google.cloud.Timestamp DEFAULT_INCLUSIVE_END_AT

The default end timestamp for a change stream query is MAX_INCLUSIVE_END_AT.

DEFAULT_RPC_PRIORITY

public static final com.google.cloud.spanner.Options.RpcPriority DEFAULT_RPC_PRIORITY

The default priority for a change stream query is Options.RpcPriority.HIGH.

THROUGHPUT_WINDOW_SECONDS

public static final int THROUGHPUT_WINDOW_SECONDS

The sliding window size in seconds for throughput reporting.

See Also:

Constant Field Values

SAMPLE_PARTITION

public static final PartitionMetadata SAMPLE_PARTITION

We use a bogus partition here to estimate the average size of a partition metadata record.

The only dynamically allocated size field here is the "parentTokens", which is a set and can expand. In practice, however, partitions have 1 to 2 parents at most.

Constructor Detail

ChangeStreamsConstants

public ChangeStreamsConstants()