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

Class SpannerAccessor

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

public class SpannerAccessor
extends Object
implements AutoCloseable

Manages lifecycle of DatabaseClient and Spanner instances.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXPERIMENTAL_HOST_INSTANCE_ID	Instance ID to use when connecting to an experimental host.

Method Summary

Modifier and Type	Method	Description
void	close()
BatchClient	getBatchClient()
DatabaseAdminClient	getDatabaseAdminClient()
DatabaseClient	getDatabaseClient()
String	getInstanceConfigId()
static SpannerAccessor	getOrCreate(SpannerConfig spannerConfig)

Methods inherited from class java.lang.Object

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

Field Details

EXPERIMENTAL_HOST_INSTANCE_ID

public static final String EXPERIMENTAL_HOST_INSTANCE_ID

Instance ID to use when connecting to an experimental host.

See Also:

• Constant Field Values

Method Details

getOrCreate

public static SpannerAccessor getOrCreate(SpannerConfig spannerConfig)

getDatabaseClient

public DatabaseClient getDatabaseClient()

getBatchClient

public BatchClient getBatchClient()

getDatabaseAdminClient

public DatabaseAdminClient getDatabaseAdminClient()

getInstanceConfigId

public String getInstanceConfigId()

close

public void close()

Specified by:

close in interface AutoCloseable