public interface RestrictionTracker<RestrictionT>
|Modifier and Type||Method and Description|
Called by the runner after
Signals that the current
Returns a restriction accurately describing the full range of work the current
DoFn.ProcessElementcall will do, including already completed work.
DoFn.ProcessElementcall should terminate as soon as possible: after this method returns, the tracker MUST refuse all future claim calls, and
currentRestriction(). Returns a restriction representing the rest of the
work: the old value of
currentRestriction() is equivalent to the new value and the
return value of this method combined. Must be called at most once on a given object.
void checkDone() throws java.lang.IllegalStateException
Must throw an exception with an informative error message, if there is still any unclaimed work remaining in the restriction.