Google Cloud Dataflow SDK for Java, version 1.9.1
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> 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 OffsetRangeTracker ARangeTracker
for non-negative positions of typelong
.
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.