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

Class SpannerSchema

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

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

Encapsulates Cloud Spanner Schema.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
SpannerSchema()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SpannerSchema

public SpannerSchema()

Method Detail

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(com.google.cloud.spanner.Dialect dialect)

getTables

public java.util.List<java.lang.String> getTables()

getColumns

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

getKeyParts

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

getCellsMutatedPerColumn

public long getCellsMutatedPerColumn(java.lang.String table,
                                     java.lang.String column)

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

getCellsMutatedPerRow

public long getCellsMutatedPerRow(java.lang.String table)

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