Package org.apache.beam.sdk.fn.splittabledofn

Class RestrictionTrackers

java.lang.Object

org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers

public class RestrictionTrackers
extends Object

Support utilities for interacting with RestrictionTrackers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RestrictionTrackers.ClaimObserver<PositionT>	Interface allowing a runner to observe the calls to RestrictionTracker.tryClaim(PositionT).

Constructor Summary

Constructors

Constructor	Description
RestrictionTrackers()

Method Summary

Modifier and Type	Method	Description
static <RestrictionT, PositionT> RestrictionTracker<RestrictionT,PositionT>	observe(RestrictionTracker<RestrictionT,PositionT> restrictionTracker, RestrictionTrackers.ClaimObserver<PositionT> claimObserver)	Returns a thread safe RestrictionTracker which reports all claim attempts to the specified RestrictionTrackers.ClaimObserver.
static <RestrictionT, PositionT> RestrictionTracker<RestrictionT,PositionT>	synchronize(RestrictionTracker<RestrictionT,PositionT> restrictionTracker)

Methods inherited from class java.lang.Object

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

Constructor Details

RestrictionTrackers

public RestrictionTrackers()

Method Details

observe

public static <RestrictionT,
PositionT>
RestrictionTracker<RestrictionT,PositionT> observe(RestrictionTracker<RestrictionT,PositionT> restrictionTracker,
 RestrictionTrackers.ClaimObserver<PositionT> claimObserver)

Returns a thread safe RestrictionTracker which reports all claim attempts to the specified RestrictionTrackers.ClaimObserver.

synchronize

public static <RestrictionT,
PositionT>
RestrictionTracker<RestrictionT,PositionT> synchronize(RestrictionTracker<RestrictionT,PositionT> restrictionTracker)