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

@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class) package org.apache.beam.sdk.fn.splittabledofn

Defines utilities related to executing splittable DoFn.

Related Packages

Package	Description
org.apache.beam.sdk.fn	The top level package for the Fn Execution Java libraries.

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