SpannerAccessor (Apache Beam 2.72.0)

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()

com.google.cloud.spanner.BatchClient

getBatchClient()

com.google.cloud.spanner.DatabaseAdminClient

getDatabaseAdminClient()

com.google.cloud.spanner.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 com.google.cloud.spanner.DatabaseClient getDatabaseClient()
- getBatchClient
  
  public com.google.cloud.spanner.BatchClient getBatchClient()
- getDatabaseAdminClient
  
  public com.google.cloud.spanner.DatabaseAdminClient getDatabaseAdminClient()
- getInstanceConfigId
  
  public String getInstanceConfigId()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable