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

Class DaoFactory

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.DaoFactory

All Implemented Interfaces:

Serializable

public class DaoFactory
extends Object
implements Serializable

Factory class to create data access objects to perform change stream queries and access the metadata tables. The instances created are all singletons.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor

Description

DaoFactory(SpannerConfig changeStreamSpannerConfig, String changeStreamName, List<String> tvfNameList, SpannerConfig metadataSpannerConfig, PartitionMetadataTableNames partitionMetadataTableNames, com.google.cloud.spanner.Options.RpcPriority rpcPriority, String jobName, com.google.cloud.spanner.Dialect spannerChangeStreamDatabaseDialect, com.google.cloud.spanner.Dialect metadataDatabaseDialect, boolean isMutableChangeStream)

Constructs a DaoFactory with the configuration to be used for the underlying instances.

Method Summary

Modifier and Type	Method	Description
ChangeStreamDao	getChangeStreamDao()	Creates and returns a singleton DAO instance for querying a partition change stream.
PartitionMetadataAdminDao	getPartitionMetadataAdminDao()	Creates and returns a singleton DAO instance for admin operations over the partition metadata table.
PartitionMetadataDao	getPartitionMetadataDao()	Creates and returns a singleton DAO instance for accessing the partition metadata table.
List<String>	getTvfNameList()	Returns the tvf name list.
boolean	isMutableChangeStream()

Methods inherited from class java.lang.Object

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

Constructor Details

DaoFactory

public DaoFactory(SpannerConfig changeStreamSpannerConfig,
 String changeStreamName,
 List<String> tvfNameList,
 SpannerConfig metadataSpannerConfig,
 PartitionMetadataTableNames partitionMetadataTableNames,
 com.google.cloud.spanner.Options.RpcPriority rpcPriority,
 String jobName,
 com.google.cloud.spanner.Dialect spannerChangeStreamDatabaseDialect,
 com.google.cloud.spanner.Dialect metadataDatabaseDialect,
 boolean isMutableChangeStream)

Constructs a DaoFactory with the configuration to be used for the underlying instances.

Parameters:

changeStreamSpannerConfig - the configuration for the change streams DAO

changeStreamName - the name of the change stream for the change streams DAO

tvfNameList - the list of TVF names specified to query and union

metadataSpannerConfig - the metadata tables configuration

partitionMetadataTableNames - the names of the partition metadata ddl objects

rpcPriority - the priority of the requests made by the DAO queries

jobName - the name of the running job

Method Details

getTvfNameList

public List<String> getTvfNameList()

Returns the tvf name list.

getPartitionMetadataAdminDao

public PartitionMetadataAdminDao getPartitionMetadataAdminDao()

Creates and returns a singleton DAO instance for admin operations over the partition metadata table.

This method is thread safe.

Returns:

singleton instance of the PartitionMetadataDao

getPartitionMetadataDao

public PartitionMetadataDao getPartitionMetadataDao()

Creates and returns a singleton DAO instance for accessing the partition metadata table.

This method is thread safe.

Returns:

singleton instance of the PartitionMetadataDao

getChangeStreamDao

public ChangeStreamDao getChangeStreamDao()

Creates and returns a singleton DAO instance for querying a partition change stream.

This method is thread safe.

Returns:

singleton instance of the ChangeStreamDao

isMutableChangeStream

public boolean isMutableChangeStream()