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

Class OrphanedMetadataCleaner

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.reconciler.OrphanedMetadataCleaner

@Internal
public class OrphanedMetadataCleaner
extends Object

Constructor Summary

Constructors

Constructor	Description
OrphanedMetadataCleaner()

Method Summary

Modifier and Type	Method	Description
void	addIncompleteNewPartitions(NewPartition newPartition)	Add NewPartition if it hasn't been updated for 15 minutes.
void	addMissingPartitions(List<com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange> missingPartitions)	Add all the missingPartitions.
List<NewPartition>	getOrphanedNewPartitions()	Returns a list of NewPartition that have been around for a while and do not overlap with any missing partition.

Methods inherited from class java.lang.Object

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

Constructor Details

OrphanedMetadataCleaner

public OrphanedMetadataCleaner()

Method Details

addIncompleteNewPartitions

public void addIncompleteNewPartitions(NewPartition newPartition)

Add NewPartition if it hasn't been updated for 15 minutes.

Parameters:

newPartition - new partition to clean up.

addMissingPartitions

public void addMissingPartitions(List<com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange> missingPartitions)

Add all the missingPartitions. This must be called in order evaluate orphaned new partition.

Parameters:

missingPartitions - add missingPartitions.

getOrphanedNewPartitions

public List<NewPartition> getOrphanedNewPartitions()

Returns a list of NewPartition that have been around for a while and do not overlap with any missing partition.

Must call addMissingPartitions before otherwise no orphan can be cleaned up.

Returns:

NewPartitions safe to clean up.