@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)
DoFn
.See: Description
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 | Description |
---|---|
RestrictionTrackers |
Support utilities for interacting with
RestrictionTrackers . |
WatermarkEstimators |
Support utilties for interacting with
WatermarkEstimator s. |
DoFn
.