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<RestrictionT>	Manages concurrent access to the restriction and keeps track of its claimed part for a splittable DoFn.

Class Summary

Class	Description
OffsetRange	A restriction represented by a range of integers [from, to).
OffsetRangeTracker	A RestrictionTracker for claiming offsets in an OffsetRange in a monotonically increasing fashion.

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

Defines utilities related to splittable DoFn.