@Internal public class GenerateInitialPartitionsAction extends java.lang.Object
DetectNewPartitionsDoFn
.Constructor and Description |
---|
GenerateInitialPartitionsAction(ChangeStreamMetrics metrics,
ChangeStreamDao changeStreamDao,
com.google.cloud.Timestamp endTime) |
Modifier and Type | Method and Description |
---|---|
boolean |
run(DoFn.OutputReceiver<PartitionRecord> receiver,
ManualWatermarkEstimator<Instant> watermarkEstimator,
com.google.cloud.Timestamp startTime)
The very first step of the pipeline when there are no partitions being streamed yet.
|
public GenerateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao, @Nullable com.google.cloud.Timestamp endTime)
public boolean run(DoFn.OutputReceiver<PartitionRecord> receiver, ManualWatermarkEstimator<Instant> watermarkEstimator, com.google.cloud.Timestamp startTime)