Package 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 Object

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ChangeStreamsConstants()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

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 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 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.

DEFAULT_WATERMARK_REFRESH_RATE

public static final Duration DEFAULT_WATERMARK_REFRESH_RATE

The default period for which we will re-compute the watermark of the DetectNewPartitionsDoFn stage.

Constructor Details

ChangeStreamsConstants

public ChangeStreamsConstants()