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) Creates and returns a singleton instance of an action class for processing individual ChangeStreamMutation in ReadChangeStreamPartitionDoFn.
DetectNewPartitionsAction	detectNewPartitionsAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, Instant endTime, GenerateInitialPartitionsAction generateInitialPartitionsAction, ResumeFromPreviousPipelineAction resumeFromPreviousPipelineAction, ProcessNewPartitionsAction processNewPartitionsAction) Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn.
GenerateInitialPartitionsAction	generateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao, Instant endTime) Creates and returns a singleton instance of an action class for processing DetectNewPartitionsDoFn
ProcessNewPartitionsAction	processNewPartitionsAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, Instant endTime)
ReadChangeStreamPartitionAction	readChangeStreamPartitionAction(MetadataTableDao metadataTableDao, ChangeStreamDao changeStreamDao, ChangeStreamMetrics metrics, ChangeStreamAction changeStreamAction, Duration heartbeatDuration, SizeEstimator<KV<com.google.protobuf.ByteString,com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord>> sizeEstimator) Creates and returns a singleton instance of an action class for processing ReadChangeStreamPartitionDoFn.
ResumeFromPreviousPipelineAction	resumeFromPreviousPipelineAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, Instant endTime, ProcessNewPartitionsAction processNewPartitionsAction)

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)

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,
                                                           @Nullable
                                                           Instant endTime,
                                                           GenerateInitialPartitionsAction generateInitialPartitionsAction,
                                                           ResumeFromPreviousPipelineAction resumeFromPreviousPipelineAction,
                                                           ProcessNewPartitionsAction processNewPartitionsAction)

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

This method is thread safe.

Returns:

singleton instance of the DetectNewPartitionsAction

processNewPartitionsAction

public ProcessNewPartitionsAction processNewPartitionsAction(ChangeStreamMetrics metrics,
                                                             MetadataTableDao metadataTableDao,
                                                             @Nullable
                                                             Instant endTime)

generateInitialPartitionsAction

public GenerateInitialPartitionsAction generateInitialPartitionsAction(ChangeStreamMetrics metrics,
                                                                       ChangeStreamDao changeStreamDao,
                                                                       @Nullable
                                                                       Instant endTime)

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

This method is thread safe.

Returns:

singleton instance of the GenerateInitialPartitionsAction

resumeFromPreviousPipelineAction

public ResumeFromPreviousPipelineAction resumeFromPreviousPipelineAction(ChangeStreamMetrics metrics,
                                                                         MetadataTableDao metadataTableDao,
                                                                         @Nullable
                                                                         Instant endTime,
                                                                         ProcessNewPartitionsAction processNewPartitionsAction)

readChangeStreamPartitionAction

public ReadChangeStreamPartitionAction readChangeStreamPartitionAction(MetadataTableDao metadataTableDao,
                                                                       ChangeStreamDao changeStreamDao,
                                                                       ChangeStreamMetrics metrics,
                                                                       ChangeStreamAction changeStreamAction,
                                                                       Duration heartbeatDuration,
                                                                       SizeEstimator<KV<com.google.protobuf.ByteString,com.google.cloud.bigtable.data.v2.models.ChangeStreamRecord>> sizeEstimator)

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

This method is thread safe.

Returns:

singleton instance of the ReadChangeStreamPartitionAction