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

Class SpannerTransformRegistrar.ChangeStreamReaderBuilder.Configuration

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar.CrossLanguageConfiguration

org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar.ChangeStreamReaderBuilder.Configuration

Enclosing class:

SpannerTransformRegistrar.ChangeStreamReaderBuilder

public static class SpannerTransformRegistrar.ChangeStreamReaderBuilder.Configuration
extends SpannerTransformRegistrar.CrossLanguageConfiguration

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
void	setChangeStreamName(String changeStreamName)
void	setInclusiveEndAt(@Nullable String inclusiveEndAtString)
void	setInclusiveStartAt(@Nullable String inclusiveStartAtString)
void	setMetadataDatabase(String metadataDatabase)
void	setMetadataInstance(String metadataInstance)
void	setMetadataTable(@Nullable String metadataTable)
void	setRpcPriority(@Nullable String rpcPriorityString)
void	setWatermarkRefreshRate(@Nullable String watermarkRefreshRateString)

Methods inherited from class org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar.CrossLanguageConfiguration

setDatabaseId, setEmulatorHost, setHost, setInstanceId, setProjectId

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

setChangeStreamName

public void setChangeStreamName(String changeStreamName)

setInclusiveStartAt

public void setInclusiveStartAt(@Nullable String inclusiveStartAtString)

setInclusiveEndAt

public void setInclusiveEndAt(@Nullable String inclusiveEndAtString)

setMetadataDatabase

public void setMetadataDatabase(String metadataDatabase)

setMetadataInstance

public void setMetadataInstance(String metadataInstance)

setMetadataTable

public void setMetadataTable(@Nullable String metadataTable)

setRpcPriority

public void setRpcPriority(@Nullable String rpcPriorityString)

setWatermarkRefreshRate

public void setWatermarkRefreshRate(@Nullable String watermarkRefreshRateString)