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

Class SpannerConfig

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public abstract class SpannerConfig
extends java.lang.Object
implements java.io.Serializable

Configuration for a Cloud Spanner client.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpannerConfig.Builder Builder for SpannerConfig.

Constructor Summary

Constructors

Constructor and Description
SpannerConfig()

Method Summary

Modifier and Type	Method and Description
static SpannerConfig	create()
abstract @Nullable ValueProvider<Duration>	getCommitDeadline()
abstract @Nullable ValueProvider<java.lang.String>	getDatabaseId()
abstract @Nullable ValueProvider<java.lang.String>	getEmulatorHost()
abstract @Nullable ValueProvider<java.lang.String>	getHost()
abstract @Nullable ValueProvider<java.lang.String>	getInstanceId()
abstract @Nullable ValueProvider<Duration>	getMaxCumulativeBackoff()
abstract @Nullable ValueProvider<java.lang.String>	getProjectId()
abstract com.google.cloud.spanner.Options.RpcPriority	getRpcPriority()
void	populateDisplayData(DisplayData.Builder builder)
void	validate()
SpannerConfig	withCommitDeadline(Duration commitDeadline)
SpannerConfig	withCommitDeadline(ValueProvider<Duration> commitDeadline)
SpannerConfig	withDatabaseId(java.lang.String databaseId)
SpannerConfig	withDatabaseId(ValueProvider<java.lang.String> databaseId)
SpannerConfig	withEmulatorHost(ValueProvider<java.lang.String> emulatorHost)
SpannerConfig	withHost(ValueProvider<java.lang.String> host)
SpannerConfig	withInstanceId(java.lang.String instanceId)
SpannerConfig	withInstanceId(ValueProvider<java.lang.String> instanceId)
SpannerConfig	withMaxCumulativeBackoff(Duration maxCumulativeBackoff)
SpannerConfig	withMaxCumulativeBackoff(ValueProvider<Duration> maxCumulativeBackoff)
SpannerConfig	withProjectId(java.lang.String projectId)
SpannerConfig	withProjectId(ValueProvider<java.lang.String> projectId)
SpannerConfig	withRpcPriority(com.google.cloud.spanner.Options.RpcPriority rpcPriority)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpannerConfig

public SpannerConfig()

Method Detail

getProjectId

public abstract @Nullable ValueProvider<java.lang.String> getProjectId()

getInstanceId

public abstract @Nullable ValueProvider<java.lang.String> getInstanceId()

getDatabaseId

public abstract @Nullable ValueProvider<java.lang.String> getDatabaseId()

getHost

public abstract @Nullable ValueProvider<java.lang.String> getHost()

getEmulatorHost

public abstract @Nullable ValueProvider<java.lang.String> getEmulatorHost()

getCommitDeadline

public abstract @Nullable ValueProvider<Duration> getCommitDeadline()

getMaxCumulativeBackoff

public abstract @Nullable ValueProvider<Duration> getMaxCumulativeBackoff()

getRpcPriority

public abstract com.google.cloud.spanner.Options.RpcPriority getRpcPriority()

create

public static SpannerConfig create()

validate

public void validate()

populateDisplayData

public void populateDisplayData(DisplayData.Builder builder)

withProjectId

public SpannerConfig withProjectId(ValueProvider<java.lang.String> projectId)

withProjectId

public SpannerConfig withProjectId(java.lang.String projectId)

withInstanceId

public SpannerConfig withInstanceId(ValueProvider<java.lang.String> instanceId)

withInstanceId

public SpannerConfig withInstanceId(java.lang.String instanceId)

withDatabaseId

public SpannerConfig withDatabaseId(ValueProvider<java.lang.String> databaseId)

withDatabaseId

public SpannerConfig withDatabaseId(java.lang.String databaseId)

withHost

public SpannerConfig withHost(ValueProvider<java.lang.String> host)

withEmulatorHost

public SpannerConfig withEmulatorHost(ValueProvider<java.lang.String> emulatorHost)

withCommitDeadline

public SpannerConfig withCommitDeadline(Duration commitDeadline)

withCommitDeadline

public SpannerConfig withCommitDeadline(ValueProvider<Duration> commitDeadline)

withMaxCumulativeBackoff

public SpannerConfig withMaxCumulativeBackoff(Duration maxCumulativeBackoff)

withMaxCumulativeBackoff

public SpannerConfig withMaxCumulativeBackoff(ValueProvider<Duration> maxCumulativeBackoff)

withRpcPriority

public SpannerConfig withRpcPriority(com.google.cloud.spanner.Options.RpcPriority rpcPriority)