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

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 Options.RpcPriority DEFAULT_RPC_PRIORITY

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

Constructor Detail

ChangeStreamsConstants

public ChangeStreamsConstants()