@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)
Creates and returns a singleton instance of an action class for processing individual
ChangeStreamMutation in
ReadChangeStreamPartitionDoFn . |
DetectNewPartitionsAction |
detectNewPartitionsAction(ChangeStreamMetrics metrics,
MetadataTableDao metadataTableDao,
com.google.cloud.Timestamp endTime,
GenerateInitialPartitionsAction generateInitialPartitionsAction)
Creates and returns a singleton instance of an action class for processing
DetectNewPartitionsDoFn . |
GenerateInitialPartitionsAction |
generateInitialPartitionsAction(ChangeStreamMetrics metrics,
ChangeStreamDao changeStreamDao,
com.google.cloud.Timestamp endTime)
Creates and returns a singleton instance of an action class for processing
DetectNewPartitionsDoFn |
ReadChangeStreamPartitionAction |
readChangeStreamPartitionAction(MetadataTableDao metadataTableDao,
ChangeStreamDao changeStreamDao,
ChangeStreamMetrics metrics,
ChangeStreamAction changeStreamAction,
Duration heartbeatDurationSeconds)
Creates and returns a singleton instance of an action class for processing
ReadChangeStreamPartitionDoFn . |
public ChangeStreamAction changeStreamAction(ChangeStreamMetrics metrics)
ReadChangeStreamPartitionDoFn
.
This method is thread safe.
ChangeStreamAction
public DetectNewPartitionsAction detectNewPartitionsAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, @Nullable com.google.cloud.Timestamp endTime, GenerateInitialPartitionsAction generateInitialPartitionsAction)
DetectNewPartitionsDoFn
.
This method is thread safe.
DetectNewPartitionsAction
public GenerateInitialPartitionsAction generateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao, @Nullable com.google.cloud.Timestamp endTime)
DetectNewPartitionsDoFn
This method is thread safe.
GenerateInitialPartitionsAction
public ReadChangeStreamPartitionAction readChangeStreamPartitionAction(MetadataTableDao metadataTableDao, ChangeStreamDao changeStreamDao, ChangeStreamMetrics metrics, ChangeStreamAction changeStreamAction, Duration heartbeatDurationSeconds)
ReadChangeStreamPartitionDoFn
.
This method is thread safe.
ReadChangeStreamPartitionAction