org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction

Class DetectNewPartitionsRangeTracker

java.lang.Object

org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker<TimestampRange,com.google.cloud.Timestamp>

org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.TimestampRangeTracker

org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.DetectNewPartitionsRangeTracker

All Implemented Interfaces:

RestrictionTracker.HasProgress

public class DetectNewPartitionsRangeTracker
extends TimestampRangeTracker

This restriction tracker delegates most of its behavior to an internal TimestampRangeTracker. It has a different logic for tryClaim method. It ignores claims for the same timestamp multiple times.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker

RestrictionTracker.HasProgress, RestrictionTracker.IsBounded, RestrictionTracker.Progress, RestrictionTracker.TruncateResult<RestrictionT>

Field Summary

Fields inherited from class org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.TimestampRangeTracker

lastAttemptedPosition, lastClaimedPosition, range, timeSupplier

Constructor Summary

Constructors

Constructor and Description
DetectNewPartitionsRangeTracker(TimestampRange range)

Method Summary

Modifier and Type	Method and Description
boolean	tryClaim(com.google.cloud.Timestamp position) Attempts to claim the given position.

Methods inherited from class org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.TimestampRangeTracker

checkDone, currentRestriction, getProgress, isBounded, setTimeSupplier, trySplit

Methods inherited from class java.lang.Object

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

Constructor Detail

DetectNewPartitionsRangeTracker

public DetectNewPartitionsRangeTracker(TimestampRange range)

Method Detail

tryClaim

public boolean tryClaim(com.google.cloud.Timestamp position)

Attempts to claim the given position.

Must be equal or larger than the last successfully claimed position.

Overrides:

tryClaim in class TimestampRangeTracker

Returns:

true if the position was successfully claimed, false if it is outside the current TimestampRange of this tracker (in that case this operation is a no-op).