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 java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	DEFAULT_CHANGE_STREAM_NAME	The default change stream name for a change stream query is the empty String.
static int	DEFAULT_HEARTBEAT_MILLIS
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 org.joda.time.Duration	DEFAULT_REAL_TIME_CHECKPOINT_INTERVAL
static com.google.cloud.spanner.Options.RpcPriority	DEFAULT_RPC_PRIORITY	The default priority for a change stream query is Options.RpcPriority.HIGH.
static org.joda.time.Duration	DEFAULT_WATERMARK_REFRESH_RATE	The default period for which we will re-compute the watermark of the DetectNewPartitionsDoFn stage.
static int	LOW_LATENCY_DEFAULT_HEARTBEAT_MILLIS
static org.joda.time.Duration	LOW_LATENCY_REAL_TIME_CHECKPOINT_INTERVAL
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	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_REAL_TIME_CHECKPOINT_INTERVAL

public static final org.joda.time.Duration DEFAULT_REAL_TIME_CHECKPOINT_INTERVAL

DEFAULT_HEARTBEAT_MILLIS

public static final int DEFAULT_HEARTBEAT_MILLIS

See Also:

Constant Field Values

LOW_LATENCY_DEFAULT_HEARTBEAT_MILLIS

public static final int LOW_LATENCY_DEFAULT_HEARTBEAT_MILLIS

See Also:

Constant Field Values

LOW_LATENCY_REAL_TIME_CHECKPOINT_INTERVAL

public static final org.joda.time.Duration LOW_LATENCY_REAL_TIME_CHECKPOINT_INTERVAL

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.

DEFAULT_WATERMARK_REFRESH_RATE

public static final org.joda.time.Duration DEFAULT_WATERMARK_REFRESH_RATE

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

Constructor Detail

ChangeStreamsConstants

public ChangeStreamsConstants()