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

Class ReadOperation

java.lang.Object

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

All Implemented Interfaces:

Serializable

public abstract class ReadOperation
extends Object
implements Serializable

Encapsulates a spanner read operation.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ReadOperation()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ReadOperation

public ReadOperation()

Method Details

create

public static ReadOperation create()

getQuery

public abstract @Nullable Statement getQuery()

getQueryName

public abstract @Nullable String getQueryName()

getTable

public abstract @Nullable String getTable()

getIndex

public abstract @Nullable String getIndex()

getColumns

public abstract @Nullable List<String> getColumns()

getKeySet

public abstract @Nullable KeySet getKeySet()

withTable

public ReadOperation withTable(String table)

withColumns

public ReadOperation withColumns(String... columns)

withColumns

public ReadOperation withColumns(List<String> columns)

withQuery

public ReadOperation withQuery(Statement statement)

withQuery

public ReadOperation withQuery(String sql)

withQueryName

public ReadOperation withQueryName(String queryName)

withKeySet

public ReadOperation withKeySet(KeySet keySet)

withIndex

public ReadOperation withIndex(String index)

withPartitionOptions

public ReadOperation withPartitionOptions(PartitionOptions partitionOptions)