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

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.
Sizes.HasSize	RestrictionTrackers which can provide a size should implement this interface.

Class Summary

Class	Description
ByteKeyRangeTracker	A RestrictionTracker for claiming ByteKeys in a ByteKeyRange in a monotonically increasing fashion.
OffsetRangeTracker	A RestrictionTracker for claiming offsets in an OffsetRange in a monotonically increasing fashion.
RestrictionTracker<RestrictionT,PositionT>	Manages access to the restriction and keeps track of its claimed part for a splittable DoFn.
Sizes	Definitions and convenience methods for reporting sizes for SplittableDoFns.
SplitResult<RestrictionT>	A representation of a split result.

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

Defines utilities related to splittable DoFn.