@Experimental(value=SOURCE_SINK)

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

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

See: Description

Class Summary

Class	Description
MutationGroup	A bundle of mutations that must be submitted atomically.
ReadOperation	Encapsulates a spanner read operation.
SpannerAccessor	Manages lifecycle of DatabaseClient and Spanner instances.
SpannerConfig	Configuration for a Cloud Spanner client.
SpannerConfig.Builder	Builder for SpannerConfig.
SpannerIO	Experimental Transforms for reading from and writing to Google 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.Write	A PTransform that writes Mutation objects to Google Cloud Spanner.
SpannerIO.WriteGrouped	Same as SpannerIO.Write but supports grouped mutations.
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.
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.