public abstract static class SpannerIO.ReadAll extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ReadOperation>,org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct>>
SpannerIO.readAll()
.Constructor and Description |
---|
ReadAll() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct> |
expand(org.apache.beam.sdk.values.PCollection<ReadOperation> input) |
SpannerIO.ReadAll |
withBatching(boolean batching)
By default Batch API is used to read data from Cloud Spanner.
|
SpannerIO.ReadAll |
withDatabaseId(java.lang.String databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.ReadAll |
withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.ReadAll |
withEmulatorHost(java.lang.String emulatorHost) |
SpannerIO.ReadAll |
withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
Specifies the Cloud Spanner emulator host.
|
SpannerIO.ReadAll |
withHost(java.lang.String host) |
SpannerIO.ReadAll |
withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
Specifies the Cloud Spanner host.
|
SpannerIO.ReadAll |
withInstanceId(java.lang.String instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.ReadAll |
withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.ReadAll |
withProjectId(java.lang.String projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.ReadAll |
withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.ReadAll |
withSpannerConfig(SpannerConfig spannerConfig)
Specifies the Cloud Spanner configuration.
|
SpannerIO.ReadAll |
withTimestamp(com.google.cloud.Timestamp timestamp) |
SpannerIO.ReadAll |
withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound) |
SpannerIO.ReadAll |
withTransaction(org.apache.beam.sdk.values.PCollectionView<Transaction> transaction) |
public SpannerIO.ReadAll withSpannerConfig(SpannerConfig spannerConfig)
public SpannerIO.ReadAll withProjectId(java.lang.String projectId)
public SpannerIO.ReadAll withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
public SpannerIO.ReadAll withInstanceId(java.lang.String instanceId)
public SpannerIO.ReadAll withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
public SpannerIO.ReadAll withDatabaseId(java.lang.String databaseId)
public SpannerIO.ReadAll withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
public SpannerIO.ReadAll withHost(java.lang.String host)
public SpannerIO.ReadAll withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
public SpannerIO.ReadAll withEmulatorHost(java.lang.String emulatorHost)
public SpannerIO.ReadAll withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
public SpannerIO.ReadAll withTransaction(org.apache.beam.sdk.values.PCollectionView<Transaction> transaction)
public SpannerIO.ReadAll withTimestamp(com.google.cloud.Timestamp timestamp)
public SpannerIO.ReadAll withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound)
public SpannerIO.ReadAll withBatching(boolean batching)
public org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct> expand(org.apache.beam.sdk.values.PCollection<ReadOperation> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<ReadOperation>,org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct>>