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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
OrphanedMetadataCleaner()

Method Summary

Modifier and Type	Method and Description
void	addIncompleteNewPartitions(NewPartition newPartition) Add NewPartition if it hasn't been updated for 15 minutes.
void	addMissingPartitions(java.util.List<com.google.cloud.bigtable.data.v2.models.Range.ByteStringRange> missingPartitions) Add all the missingPartitions.
java.util.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 Detail

OrphanedMetadataCleaner

public OrphanedMetadataCleaner()

Method Detail

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(java.util.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 java.util.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.