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

Class SpannerSchema

java.lang.Object

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

All Implemented Interfaces:

Serializable

public abstract class SpannerSchema
extends Object
implements Serializable

Encapsulates Cloud Spanner Schema.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SpannerSchema.Column
static class	SpannerSchema.KeyPart

Constructor Summary

Constructors

Constructor	Description
SpannerSchema()

Method Summary

Modifier and Type	Method	Description
static org.apache.beam.sdk.io.gcp.spanner.SpannerSchema.Builder	builder()
static org.apache.beam.sdk.io.gcp.spanner.SpannerSchema.Builder	builder(Dialect dialect)
long	getCellsMutatedPerColumn(String table, String column)	Return the total number of cells affected when the specified column is mutated.
long	getCellsMutatedPerRow(String table)	Return the total number of cells affected with the given row is deleted.
List<SpannerSchema.Column>	getColumns(String table)
List<SpannerSchema.KeyPart>	getKeyParts(String table)
List<String>	getTables()

Methods inherited from class java.lang.Object

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

Constructor Details

SpannerSchema

public SpannerSchema()

Method Details

builder

public static org.apache.beam.sdk.io.gcp.spanner.SpannerSchema.Builder builder()

builder

public static org.apache.beam.sdk.io.gcp.spanner.SpannerSchema.Builder builder(Dialect dialect)

getTables

public List<String> getTables()

getColumns

public List<SpannerSchema.Column> getColumns(String table)

getKeyParts

public List<SpannerSchema.KeyPart> getKeyParts(String table)

getCellsMutatedPerColumn

public long getCellsMutatedPerColumn(String table,
 String column)

Return the total number of cells affected when the specified column is mutated.

getCellsMutatedPerRow

public long getCellsMutatedPerRow(String table)

Return the total number of cells affected with the given row is deleted.