Package com.google.cloud.dataflow.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
OffsetRangeTracker	A RangeTracker for non-negative positions of type long.

Package com.google.cloud.dataflow.sdk.io.range Description

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

See RangeTracker to get started.