@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class)
Package org.apache.beam.sdk.io.range
Provides thread-safe helpers for implementing dynamic work rebalancing in position-based bounded
sources.
See RangeTracker
to get started.
-
Interface Summary Interface Description RangeTracker<PositionT> ARangeTracker
is a thread-safe helper object for implementing dynamic work rebalancing in position-basedBoundedSource.BoundedReader
subclasses. -
Class Summary Class Description ByteKey A class representing a key consisting of an array of bytes.ByteKeyRange A class representing a range ofByteKeys
.ByteKeyRangeTracker OffsetRange A restriction represented by a range of integers [from, to).OffsetRange.Coder A coder forOffsetRange
s.OffsetRangeTracker ARangeTracker
for non-negative positions of typelong
.