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

Provides an API for reading from and writing to Google Cloud Spanner.

See: Description

Interface Summary

Interface	Description
SpannerIO.SpannerChangeStreamOptions	Interface to display the name of the metadata table on Dataflow UI.

Class Summary

Class	Description
MutationGroup	A bundle of mutations that must be submitted atomically.
ReadOperation	Encapsulates a spanner read operation.
ReadSpannerSchema	This DoFn reads Cloud Spanner 'information_schema.*' tables to build the SpannerSchema.
SpannerAccessor	Manages lifecycle of DatabaseClient and Spanner instances.
SpannerConfig	Configuration for a Cloud Spanner client.
SpannerConfig.Builder	Builder for SpannerConfig.
SpannerIO	Reading from Cloud Spanner
SpannerIO.CreateTransaction	A PTransform that create a transaction.
SpannerIO.CreateTransaction.Builder	A builder for SpannerIO.CreateTransaction.
SpannerIO.Read	Implementation of SpannerIO.read().
SpannerIO.ReadAll	Implementation of SpannerIO.readAll().
SpannerIO.ReadChangeStream
SpannerIO.Write	A PTransform that writes Mutation objects to Google Cloud Spanner.
SpannerIO.WriteGrouped	Same as SpannerIO.Write but supports grouped mutations.
SpannerSchema	Encapsulates Cloud Spanner Schema.
SpannerSchema.Column
SpannerSchema.KeyPart
SpannerTransformRegistrar	Exposes SpannerIO.WriteRows and SpannerIO.ReadRows as an external transform for cross-language usage.
SpannerTransformRegistrar.CrossLanguageConfiguration
SpannerTransformRegistrar.DeleteBuilder
SpannerTransformRegistrar.InsertBuilder
SpannerTransformRegistrar.InsertOrUpdateBuilder
SpannerTransformRegistrar.ReadBuilder
SpannerTransformRegistrar.ReadBuilder.Configuration
SpannerTransformRegistrar.ReplaceBuilder
SpannerTransformRegistrar.UpdateBuilder
SpannerWriteResult	The results of a SpannerIO.write() transform.
SpannerWriteSchemaTransformProvider
SpannerWriteSchemaTransformProvider.SpannerWriteSchemaTransformConfiguration
SpannerWriteSchemaTransformProvider.SpannerWriteSchemaTransformConfiguration.Builder
Transaction	A transaction object.

Enum Summary

Enum	Description
SpannerIO.FailureMode	A failure handling strategy.

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

Provides an API for reading from and writing to Google Cloud Spanner.