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

Class SpannerAccessor

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable

public class SpannerAccessor
extends java.lang.Object
implements java.lang.AutoCloseable

Manages lifecycle of DatabaseClient and Spanner instances.

Field Summary

Fields

Modifier and Type	Field and Description
static org.threeten.bp.Duration	GRPC_KEEP_ALIVE_SECONDS

Method Summary

Modifier and Type	Method and Description
void	close()
com.google.cloud.spanner.BatchClient	getBatchClient()
com.google.cloud.spanner.DatabaseAdminClient	getDatabaseAdminClient()
com.google.cloud.spanner.DatabaseClient	getDatabaseClient()
static SpannerAccessor	getOrCreate(SpannerConfig spannerConfig)

Methods inherited from class java.lang.Object

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

Field Detail

GRPC_KEEP_ALIVE_SECONDS

public static final org.threeten.bp.Duration GRPC_KEEP_ALIVE_SECONDS

Method Detail

getOrCreate

public static SpannerAccessor getOrCreate(SpannerConfig spannerConfig)

getDatabaseClient

public com.google.cloud.spanner.DatabaseClient getDatabaseClient()

getBatchClient

public com.google.cloud.spanner.BatchClient getBatchClient()

getDatabaseAdminClient

public com.google.cloud.spanner.DatabaseAdminClient getDatabaseAdminClient()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable