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

Interface RestrictionTrackers.ClaimObserver<PositionT>

Enclosing class:

RestrictionTrackers

public static interface RestrictionTrackers.ClaimObserver<PositionT>

Interface allowing a runner to observe the calls to RestrictionTracker.tryClaim(PositionT).

Method Summary

Modifier and Type	Method	Description
void	onClaimed(PositionT position)	Called when RestrictionTracker.tryClaim(PositionT) returns true.
void	onClaimFailed(PositionT position)	Called when RestrictionTracker.tryClaim(PositionT) returns false.

Method Details

onClaimed

void onClaimed(PositionT position)

Called when RestrictionTracker.tryClaim(PositionT) returns true.

onClaimFailed

void onClaimFailed(PositionT position)

Called when RestrictionTracker.tryClaim(PositionT) returns false.