org.apache.beam.sdk.io.gcp.spanner

Class ReadOperation

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.ReadOperation

All Implemented Interfaces:

java.io.Serializable

public abstract class ReadOperation
extends java.lang.Object
implements java.io.Serializable

Encapsulates a spanner read operation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReadOperation()

Method Summary

Modifier and Type	Method and Description
static ReadOperation	create()
abstract @Nullable java.util.List<java.lang.String>	getColumns()
abstract @Nullable java.lang.String	getIndex()
abstract @Nullable KeySet	getKeySet()
abstract @Nullable Statement	getQuery()
abstract @Nullable java.lang.String	getQueryName()
abstract @Nullable java.lang.String	getTable()
ReadOperation	withColumns(java.util.List<java.lang.String> columns)
ReadOperation	withColumns(java.lang.String... columns)
ReadOperation	withIndex(java.lang.String index)
ReadOperation	withKeySet(KeySet keySet)
ReadOperation	withPartitionOptions(PartitionOptions partitionOptions)
ReadOperation	withQuery(Statement statement)
ReadOperation	withQuery(java.lang.String sql)
ReadOperation	withQueryName(java.lang.String queryName)
ReadOperation	withTable(java.lang.String table)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReadOperation

public ReadOperation()

Method Detail

create

public static ReadOperation create()

getQuery

public abstract @Nullable Statement getQuery()

getQueryName

public abstract @Nullable java.lang.String getQueryName()

getTable

public abstract @Nullable java.lang.String getTable()

getIndex

public abstract @Nullable java.lang.String getIndex()

getColumns

public abstract @Nullable java.util.List<java.lang.String> getColumns()

getKeySet

public abstract @Nullable KeySet getKeySet()

withTable

public ReadOperation withTable(java.lang.String table)

withColumns

public ReadOperation withColumns(java.lang.String... columns)

withColumns

public ReadOperation withColumns(java.util.List<java.lang.String> columns)

withQuery

public ReadOperation withQuery(Statement statement)

withQuery

public ReadOperation withQuery(java.lang.String sql)

withQueryName

public ReadOperation withQueryName(java.lang.String queryName)

withKeySet

public ReadOperation withKeySet(KeySet keySet)

withIndex

public ReadOperation withIndex(java.lang.String index)

withPartitionOptions

public ReadOperation withPartitionOptions(PartitionOptions partitionOptions)