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

Class GenerateInitialPartitionsAction

java.lang.Object

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

@Internal
public class GenerateInitialPartitionsAction
extends Object

Class to generate first set of outputs for DetectNewPartitionsDoFn.

Constructor Summary

Constructors

Constructor	Description
GenerateInitialPartitionsAction(ChangeStreamMetrics metrics, ChangeStreamDao changeStreamDao, Instant endTime)

Method Summary

Modifier and Type	Method	Description
void	run(DoFn.OutputReceiver<PartitionRecord> receiver, Instant startTime)	The very first step of the pipeline when there are no partitions being streamed yet.

Methods inherited from class java.lang.Object

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

Constructor Details

GenerateInitialPartitionsAction

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

Method Details

run

public void run(DoFn.OutputReceiver<PartitionRecord> receiver,
 Instant startTime)

The very first step of the pipeline when there are no partitions being streamed yet. We want to get an initial list of partitions to stream and output them.