public abstract static class SpannerIO.CreateTransaction extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollectionView<Transaction>>
PTransform
that create a transaction.SpannerIO
,
Serialized FormModifier and Type | Class and Description |
---|---|
static class |
SpannerIO.CreateTransaction.Builder
A builder for
SpannerIO.CreateTransaction . |
Constructor and Description |
---|
CreateTransaction() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollectionView<Transaction> |
expand(org.apache.beam.sdk.values.PBegin input) |
SpannerIO.CreateTransaction |
withDatabaseId(java.lang.String databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.CreateTransaction |
withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.CreateTransaction |
withEmulatorHost(java.lang.String emulatorHost) |
SpannerIO.CreateTransaction |
withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
Specifies the Cloud Spanner emulator host.
|
SpannerIO.CreateTransaction |
withHost(java.lang.String host) |
SpannerIO.CreateTransaction |
withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
Specifies the Cloud Spanner host.
|
SpannerIO.CreateTransaction |
withInstanceId(java.lang.String instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.CreateTransaction |
withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.CreateTransaction |
withProjectId(java.lang.String projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.CreateTransaction |
withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.CreateTransaction |
withSpannerConfig(SpannerConfig spannerConfig)
Specifies the Cloud Spanner configuration.
|
SpannerIO.CreateTransaction |
withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound) |
public org.apache.beam.sdk.values.PCollectionView<Transaction> expand(org.apache.beam.sdk.values.PBegin input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollectionView<Transaction>>
public SpannerIO.CreateTransaction withSpannerConfig(SpannerConfig spannerConfig)
public SpannerIO.CreateTransaction withProjectId(java.lang.String projectId)
public SpannerIO.CreateTransaction withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
public SpannerIO.CreateTransaction withInstanceId(java.lang.String instanceId)
public SpannerIO.CreateTransaction withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
public SpannerIO.CreateTransaction withDatabaseId(java.lang.String databaseId)
public SpannerIO.CreateTransaction withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
public SpannerIO.CreateTransaction withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
public SpannerIO.CreateTransaction withHost(java.lang.String host)
public SpannerIO.CreateTransaction withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
public SpannerIO.CreateTransaction withEmulatorHost(java.lang.String emulatorHost)
public SpannerIO.CreateTransaction withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound)