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

Class SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

SpannerChangestreamsReadSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
SpannerChangestreamsReadConfiguration()

Method Summary

Modifier and Type	Method	Description
static SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration.Builder	builder()
abstract String	getChangeStreamName()
abstract String	getDatabaseId()
abstract @Nullable String	getEndAtTimestamp()
abstract String	getInstanceId()
abstract String	getProjectId()
abstract String	getStartAtTimestamp()
abstract String	getTable()

Methods inherited from class java.lang.Object

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

Constructor Details

SpannerChangestreamsReadConfiguration

public SpannerChangestreamsReadConfiguration()

Method Details

getDatabaseId

@SchemaFieldDescription("Specifies the Cloud Spanner database.")
public abstract String getDatabaseId()

getProjectId

@SchemaFieldDescription("Specifies the Cloud Spanner project.")
public abstract String getProjectId()

getInstanceId

@SchemaFieldDescription("Specifies the Cloud Spanner instance.")
public abstract String getInstanceId()

getTable

@SchemaFieldDescription("Specifies the Cloud Spanner table.")
public abstract String getTable()

getStartAtTimestamp

@SchemaFieldDescription("Specifies the time that the change stream should be read from.")
public abstract String getStartAtTimestamp()

getEndAtTimestamp

@SchemaFieldDescription("Specifies the end time of the change stream.")
public abstract @Nullable String getEndAtTimestamp()

getChangeStreamName

@SchemaFieldDescription("Specifies the change stream name.")
public abstract String getChangeStreamName()

builder

public static SpannerChangestreamsReadSchemaTransformProvider.SpannerChangestreamsReadConfiguration.Builder builder()