com.google.cloud.dataflow.sdk.io.range (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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
  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.
  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.