org.apache.beam.sdk.transforms.splittabledofn

Interface RestrictionTracker.ClaimObserver<PositionT>

Enclosing class:

RestrictionTracker<RestrictionT,PositionT>

@Internal
public static interface RestrictionTracker.ClaimObserver<PositionT>

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

Method Summary

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

Method Detail

onClaimed

void onClaimed(PositionT position)

Called when RestrictionTracker.tryClaim(PositionT) returns true.

onClaimFailed

void onClaimFailed(PositionT position)

Called when RestrictionTracker.tryClaim(PositionT) returns false.