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

Class ResumeFromPreviousPipelineAction

java.lang.Object

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

public class ResumeFromPreviousPipelineAction
extends Object

Constructor Summary

Constructors

Constructor	Description
ResumeFromPreviousPipelineAction(ChangeStreamMetrics metrics, MetadataTableDao metadataTableDao, Instant endTime, ProcessNewPartitionsAction processNewPartitionsAction)

Method Summary

Modifier and Type	Method	Description
void	run(DoFn.OutputReceiver<PartitionRecord> receiver)	Resume from previously drained pipeline.

Methods inherited from class java.lang.Object

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

Constructor Details

ResumeFromPreviousPipelineAction

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

Method Details

run

public void run(DoFn.OutputReceiver<PartitionRecord> receiver)
         throws InvalidProtocolBufferException

Resume from previously drained pipeline. Restart StreamPartitions by reading the last metadata write and output PartitionRecord based on that. Process NewPartitions normally.

1. Clear out missing partitions metadata in the metadata table
2. Read all StreamPartitions and output them
3. Read all NewPartitions and output them normally

Parameters:

receiver - output receiver to output

Throws:

InvalidProtocolBufferException - when failing to read from metadata table.