Package 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:

Serializable

public class MapperFactory
extends Object
implements 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	Description
MapperFactory(Dialect spannerChangeStreamDatabaseDialect)

Method Summary

Modifier and Type	Method	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 Details

MapperFactory

public MapperFactory(Dialect spannerChangeStreamDatabaseDialect)

Method Details

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