@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
Backlogs.HasBacklog	RestrictionTrackers which can provide a backlog should implement this interface.
Backlogs.HasPartitionedBacklog	RestrictionTrackers which can provide a backlog that is from a shared resource such as a message queue should implement this interface to provide the partition identifier.
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.

Class Summary

Class	Description
Backlog	A representation for the amount of known work represented as a backlog.
Backlogs	Definitions and convenience methods for reporting/consuming/updating backlogs.
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.

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

Defines utilities related to splittable DoFn.