public abstract static class SpannerIO.Read
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct>>
SpannerIO.read()
.Constructor and Description |
---|
Read() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct> |
expand(org.apache.beam.sdk.values.PBegin input) |
SpannerIO.Read |
withBatching(boolean batching)
If true the uses Cloud Spanner batch API.
|
SpannerIO.Read |
withColumns(java.util.List<java.lang.String> columns) |
SpannerIO.Read |
withColumns(java.lang.String... columns) |
SpannerIO.Read |
withDatabaseId(java.lang.String databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.Read |
withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
Specifies the Cloud Spanner database.
|
SpannerIO.Read |
withEmulatorHost(java.lang.String emulatorHost) |
SpannerIO.Read |
withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
Specifies the Cloud Spanner emulator host.
|
SpannerIO.Read |
withHost(java.lang.String host) |
SpannerIO.Read |
withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
Specifies the Cloud Spanner host.
|
SpannerIO.Read |
withIndex(java.lang.String index) |
SpannerIO.Read |
withInstanceId(java.lang.String instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.Read |
withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
Specifies the Cloud Spanner instance.
|
SpannerIO.Read |
withKeySet(com.google.cloud.spanner.KeySet keySet) |
SpannerIO.Read |
withPartitionOptions(com.google.cloud.spanner.PartitionOptions partitionOptions) |
SpannerIO.Read |
withProjectId(java.lang.String projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.Read |
withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
Specifies the Cloud Spanner project.
|
SpannerIO.Read |
withQuery(com.google.cloud.spanner.Statement statement) |
SpannerIO.Read |
withQuery(java.lang.String sql) |
SpannerIO.Read |
withReadOperation(ReadOperation operation) |
SpannerIO.Read |
withSpannerConfig(SpannerConfig spannerConfig)
Specifies the Cloud Spanner configuration.
|
SpannerIO.Read |
withTable(java.lang.String table) |
SpannerIO.Read |
withTimestamp(com.google.cloud.Timestamp timestamp) |
SpannerIO.Read |
withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound) |
SpannerIO.Read |
withTransaction(org.apache.beam.sdk.values.PCollectionView<Transaction> transaction) |
public SpannerIO.Read withSpannerConfig(SpannerConfig spannerConfig)
public SpannerIO.Read withProjectId(java.lang.String projectId)
public SpannerIO.Read withProjectId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> projectId)
public SpannerIO.Read withInstanceId(java.lang.String instanceId)
public SpannerIO.Read withInstanceId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> instanceId)
public SpannerIO.Read withDatabaseId(java.lang.String databaseId)
public SpannerIO.Read withDatabaseId(org.apache.beam.sdk.options.ValueProvider<java.lang.String> databaseId)
public SpannerIO.Read withHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> host)
public SpannerIO.Read withHost(java.lang.String host)
public SpannerIO.Read withEmulatorHost(org.apache.beam.sdk.options.ValueProvider<java.lang.String> emulatorHost)
public SpannerIO.Read withEmulatorHost(java.lang.String emulatorHost)
public SpannerIO.Read withBatching(boolean batching)
public SpannerIO.Read withTransaction(org.apache.beam.sdk.values.PCollectionView<Transaction> transaction)
public SpannerIO.Read withTimestamp(com.google.cloud.Timestamp timestamp)
public SpannerIO.Read withTimestampBound(com.google.cloud.spanner.TimestampBound timestampBound)
public SpannerIO.Read withTable(java.lang.String table)
public SpannerIO.Read withReadOperation(ReadOperation operation)
public SpannerIO.Read withColumns(java.lang.String... columns)
public SpannerIO.Read withColumns(java.util.List<java.lang.String> columns)
public SpannerIO.Read withQuery(com.google.cloud.spanner.Statement statement)
public SpannerIO.Read withQuery(java.lang.String sql)
public SpannerIO.Read withKeySet(com.google.cloud.spanner.KeySet keySet)
public SpannerIO.Read withIndex(java.lang.String index)
public SpannerIO.Read withPartitionOptions(com.google.cloud.spanner.PartitionOptions partitionOptions)
public org.apache.beam.sdk.values.PCollection<com.google.cloud.spanner.Struct> 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.PCollection<com.google.cloud.spanner.Struct>>