Package org.apache.beam.sdk.io.range
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.
-
ClassDescriptionA class representing a key consisting of an array of bytes.A class representing a range of
ByteKeys.A restriction represented by a range of integers [from, to).A coder forOffsetRanges.ARangeTrackerfor non-negative positions of typelong.RangeTracker<PositionT>ARangeTrackeris a thread-safe helper object for implementing dynamic work rebalancing in position-basedBoundedSource.BoundedReadersubclasses.