Package org.apache.beam.sdk.io.gcp.spanner
package org.apache.beam.sdk.io.gcp.spanner
Provides an API for reading from and writing to Google Cloud Spanner.
-
ClassDescriptionA bundle of mutations that must be submitted atomically.Encapsulates a spanner read operation.This
DoFn
reads Cloud Spanner 'information_schema.*' tables to build theSpannerSchema
.Manages lifecycle ofDatabaseClient
andSpanner
instances.Configuration for a Cloud Spanner client.Builder forSpannerConfig
.Reading from Cloud SpannerAPTransform
that create a transaction.A builder forSpannerIO.CreateTransaction
.A failure handling strategy.Implementation ofSpannerIO.read()
.Implementation ofSpannerIO.readAll()
.Interface to display the name of the metadata table on Dataflow UI.APTransform
that writesMutation
objects to Google Cloud Spanner.Same asSpannerIO.Write
but supports grouped mutations.A provider for reading from Cloud Spanner using a Schema Transform Provider.Encapsulates Cloud Spanner Schema.Exception to signal that Spanner schema retrieval failed.ExposesSpannerIO.WriteRows
andSpannerIO.ReadRows
as an external transform for cross-language usage.The results of aSpannerIO.write()
transform.A transaction object.