org.apache.beam.sdk.fn.splittabledofn

Class RestrictionTrackers

java.lang.Object

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

public class RestrictionTrackers
extends java.lang.Object

Support utilities for interacting with RestrictionTrackers.

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
RestrictionTrackers()

Method Summary

Modifier and Type	Method and 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

RestrictionTrackers

public RestrictionTrackers()

Method Detail

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.