Package org.apache.beam.sdk.io.range

Provides thread-safe helpers for implementing dynamic work rebalancing in position-based bounded sources.

See: Description

Interface Summary

Interface	Description
RangeTracker<PositionT>	A RangeTracker is a thread-safe helper object for implementing dynamic work rebalancing in position-based BoundedSource.BoundedReader subclasses.

Class Summary

Class	Description
ByteKey	A class representing a key consisting of an array of bytes.
ByteKeyRange	A class representing a range of ByteKeys.
ByteKeyRangeTracker	A RangeTracker for ByteKeys in ByteKeyRanges.
OffsetRange	A restriction represented by a range of integers [from, to).
OffsetRangeTracker	A RangeTracker for non-negative positions of type long.

Package org.apache.beam.sdk.io.range Description

Provides thread-safe helpers for implementing dynamic work rebalancing in position-based bounded sources.

See RangeTracker to get started.