public abstract class SpannerConfig
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
SpannerConfig.Builder
Builder for
SpannerConfig . |
Constructor and Description |
---|
SpannerConfig() |
Modifier and Type | Method and Description |
---|---|
static SpannerConfig |
create() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> |
getCommitDeadline() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getDatabaseId() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getEmulatorHost() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getHost() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getInstanceId() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> |
getMaxCumulativeBackoff() |
abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getProjectId() |
void |
populateDisplayData(org.apache.beam.sdk.transforms.display.DisplayData.Builder builder) |
void |
validate() |
SpannerConfig |
withCommitDeadline(org.joda.time.Duration commitDeadline) |
SpannerConfig |
withCommitDeadline(org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> commitDeadline) |
SpannerConfig |
withDatabaseId(java.lang.String databaseId) |
SpannerConfig |
withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId) |
SpannerConfig |
withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost) |
SpannerConfig |
withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host) |
SpannerConfig |
withInstanceId(java.lang.String instanceId) |
SpannerConfig |
withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId) |
SpannerConfig |
withMaxCumulativeBackoff(org.joda.time.Duration maxCumulativeBackoff) |
SpannerConfig |
withMaxCumulativeBackoff(org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> maxCumulativeBackoff) |
SpannerConfig |
withProjectId(java.lang.String projectId) |
SpannerConfig |
withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId) |
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> getProjectId()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> getInstanceId()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> getDatabaseId()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> getHost()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<java.lang.String> getEmulatorHost()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> getCommitDeadline()
public abstract @Nullable org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> getMaxCumulativeBackoff()
public static SpannerConfig create()
public void validate()
public void populateDisplayData(org.apache.beam.sdk.transforms.display.DisplayData.Builder builder)
public SpannerConfig withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
public SpannerConfig withProjectId(java.lang.String projectId)
public SpannerConfig withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
public SpannerConfig withInstanceId(java.lang.String instanceId)
public SpannerConfig withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
public SpannerConfig withDatabaseId(java.lang.String databaseId)
public SpannerConfig withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
public SpannerConfig withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
public SpannerConfig withCommitDeadline(org.joda.time.Duration commitDeadline)
public SpannerConfig withCommitDeadline(org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> commitDeadline)
public SpannerConfig withMaxCumulativeBackoff(org.joda.time.Duration maxCumulativeBackoff)
public SpannerConfig withMaxCumulativeBackoff(org.apache.beam.sdk.options.ValueProvider<org.joda.time.Duration> maxCumulativeBackoff)