@DefaultAnnotation(value=org.checkerframework.checker.nullness.qual.NonNull.class)

Package org.apache.beam.sdk.fn.splittabledofn

Defines utilities related to executing splittable DoFn.

See: Description

Interface Summary

Interface	Description
RestrictionTrackers.ClaimObserver<PositionT>	Interface allowing a runner to observe the calls to RestrictionTracker.tryClaim(PositionT).
WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT>	Interface which allows for accessing the current watermark and watermark estimator state.

Class Summary

Class	Description
RestrictionTrackers	Support utilities for interacting with RestrictionTrackers.
WatermarkEstimators	Support utilties for interacting with WatermarkEstimators.

Package org.apache.beam.sdk.fn.splittabledofn Description

Defines utilities related to executing splittable DoFn.