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

Class MapperFactory

java.lang.Object

org.apache.beam.sdk.io.gcp.spanner.changestreams.mapper.MapperFactory

All Implemented Interfaces:

java.io.Serializable

public class MapperFactory
extends java.lang.Object
implements java.io.Serializable

Factory class for creating instances that will map a struct to a connector model. The instances created are all singletons.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MapperFactory(com.google.cloud.spanner.Dialect spannerChangeStreamDatabaseDialect)

Method Summary

Modifier and Type	Method and Description
ChangeStreamRecordMapper	changeStreamRecordMapper() Creates and returns a singleton instance of a mapper class capable of transforming a Struct into a List of ChangeStreamRecord subclasses.
PartitionMetadataMapper	partitionMetadataMapper() Creates and returns a single instance of a mapper class capable of transforming a Struct into a PartitionMetadata class.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapperFactory

public MapperFactory(com.google.cloud.spanner.Dialect spannerChangeStreamDatabaseDialect)

Method Detail

changeStreamRecordMapper

public ChangeStreamRecordMapper changeStreamRecordMapper()

Creates and returns a singleton instance of a mapper class capable of transforming a Struct into a List of ChangeStreamRecord subclasses.

This method is thread safe.

Returns:

singleton instance of the ChangeStreamRecordMapper

partitionMetadataMapper

public PartitionMetadataMapper partitionMetadataMapper()

Creates and returns a single instance of a mapper class capable of transforming a Struct into a PartitionMetadata class.

This method is thread safe.

Returns:

singleton instance of the PartitionMetadataMapper