@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)

Package org.apache.beam.sdk.transforms.splittabledofn

Defines utilities related to splittable DoFn.

See: Description

Interface Summary

Interface	Description
HasDefaultTracker<RestrictionT extends HasDefaultTracker<RestrictionT,TrackerT>,TrackerT extends RestrictionTracker<RestrictionT,?>>	Interface for restrictions for which a default implementation of DoFn.NewTracker is available, depending only on the restriction itself.
RestrictionTracker.ClaimObserver<PositionT>	Internal interface allowing a runner to observe the calls to RestrictionTracker.tryClaim(PositionT).

Class Summary

Class	Description
OffsetRangeTracker	A RestrictionTracker for claiming offsets in an OffsetRange in a monotonically increasing fashion.
RestrictionTracker<RestrictionT,PositionT>	Manages concurrent access to the restriction and keeps track of its claimed part for a splittable DoFn.

Package org.apache.beam.sdk.transforms.splittabledofn Description

Defines utilities related to splittable DoFn.