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 java.util.List<java.lang.String>	getColumns()
abstract java.lang.String	getIndex()
abstract KeySet	getKeySet()
abstract Statement	getQuery()
abstract 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	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

@Nullable
public abstract Statement getQuery()

getTable

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

getIndex

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

getColumns

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

getKeySet

@Nullable
public abstract 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)

withKeySet

public ReadOperation withKeySet(KeySet keySet)

withIndex

public ReadOperation withIndex(java.lang.String index)

withPartitionOptions

public ReadOperation withPartitionOptions(PartitionOptions partitionOptions)