org.apache.beam.sdk.io.gcp.bigtable.changestreams.action

Class ActionFactory

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.action.ActionFactory

All Implemented Interfaces:

java.io.Serializable

@Internal
public class ActionFactory
extends java.lang.Object
implements java.io.Serializable

Factory class for creating instances that will handle different functions of DoFns. The instances created are all singletons.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ActionFactory()

Method Summary

Modifier and Type	Method and Description
ChangeStreamAction	changeStreamAction(ChangeStreamMetrics metrics, ThroughputEstimator<KV<com.google.protobuf.ByteString,com.google.cloud.bigtable.data.v2.models.ChangeStreamMutation>> throughputEstimator) Creates and returns a singleton instance of an action class for processing individual ChangeStreamMutation in ReadChangeStreamPartitionDoFn.
DetectNewPartitionsAction	detectNewPartitionsAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, GenerateInitialPartitionsAction generateInitialPartitionsAction) Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn.
GenerateInitialPartitionsAction	generateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao) Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn
ReadChangeStreamPartitionAction	readChangeStreamPartitionAction(MetadataTableDao metadataTableDao, ChangeStreamDao changeStreamDao, ChangeStreamMetrics metrics, ChangeStreamAction changeStreamAction, Duration heartbeatDuration) Creates and returns a singleton instance of an action class for processing ReadChangeStreamPartitionDoFn.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActionFactory

public ActionFactory()

Method Detail

changeStreamAction

public ChangeStreamAction changeStreamAction(ChangeStreamMetrics metrics,
                                             ThroughputEstimator<KV<com.google.protobuf.ByteString,com.google.cloud.bigtable.data.v2.models.ChangeStreamMutation>> throughputEstimator)

Creates and returns a singleton instance of an action class for processing individual ChangeStreamMutation in ReadChangeStreamPartitionDoFn.

This method is thread safe.

Returns:

singleton instance of the ChangeStreamAction

detectNewPartitionsAction

public DetectNewPartitionsAction detectNewPartitionsAction(ChangeStreamMetrics metrics,
                                                           MetadataTableDao metadataTableDao,
                                                           GenerateInitialPartitionsAction generateInitialPartitionsAction)

Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn.

This method is thread safe.

Returns:

singleton instance of the DetectNewPartitionsAction

generateInitialPartitionsAction

public GenerateInitialPartitionsAction generateInitialPartitionsAction(ChangeStreamMetrics metrics,
                                                                       ChangeStreamDao changeStreamDao)

Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn

This method is thread safe.

Returns:

singleton instance of the GenerateInitialPartitionsAction

readChangeStreamPartitionAction

public ReadChangeStreamPartitionAction readChangeStreamPartitionAction(MetadataTableDao metadataTableDao,
                                                                       ChangeStreamDao changeStreamDao,
                                                                       ChangeStreamMetrics metrics,
                                                                       ChangeStreamAction changeStreamAction,
                                                                       Duration heartbeatDuration)

Creates and returns a singleton instance of an action class for processing ReadChangeStreamPartitionDoFn.

This method is thread safe.

Returns:

singleton instance of the ReadChangeStreamPartitionAction