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 |
withHighPriority() |
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 |
withLowPriority() |
SpannerIO.Read |
withPartitionOptions(com.google.cloud.spanner.PartitionOptions partitionOptions)
Note that
PartitionOptions are currently ignored. |
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 |
withQueryName(java.lang.String queryName) |
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) |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
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 withQueryName(java.lang.String queryName)
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)
PartitionOptions
are currently ignored. See
PartitionOptions in RPC documentspublic SpannerIO.Read withLowPriority()
public SpannerIO.Read withHighPriority()
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>>