@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)
DoFn.See: Description
| 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. |
| RestrictionTracker.ClaimObserver<PositionT> |
Internal interface allowing a runner to observe the calls to
RestrictionTracker.tryClaim(PositionT). |
| 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 | |
| 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. |
DoFn.