@Internal public class ActionFactory extends java.lang.Object implements java.io.Serializable
Constructor and Description |
---|
ActionFactory() |
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 . |
public ChangeStreamAction changeStreamAction(ChangeStreamMetrics metrics, ThroughputEstimator<KV<com.google.protobuf.ByteString,com.google.cloud.bigtable.data.v2.models.ChangeStreamMutation>> throughputEstimator)
ReadChangeStreamPartitionDoFn
.
This method is thread safe.
ChangeStreamAction
public DetectNewPartitionsAction detectNewPartitionsAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, GenerateInitialPartitionsAction generateInitialPartitionsAction)
DetectNewPartitionsDoFn
.
This method is thread safe.
DetectNewPartitionsAction
public GenerateInitialPartitionsAction generateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao)
DetectNewPartitionsDoFn
This method is thread safe.
GenerateInitialPartitionsAction
public ReadChangeStreamPartitionAction readChangeStreamPartitionAction(MetadataTableDao metadataTableDao, ChangeStreamDao changeStreamDao, ChangeStreamMetrics metrics, ChangeStreamAction changeStreamAction, Duration heartbeatDuration)
ReadChangeStreamPartitionDoFn
.
This method is thread safe.
ReadChangeStreamPartitionAction