Class WatermarkEstimators
- java.lang.Object
-
- org.apache.beam.sdk.transforms.splittabledofn.WatermarkEstimators
-
public class WatermarkEstimators extends java.lang.Object
A set ofWatermarkEstimator
s that users can use to advance the output watermark for their associatedsplittable DoFn
s.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
WatermarkEstimators.Manual
Concrete implementation of aManualWatermarkEstimator
.static class
WatermarkEstimators.MonotonicallyIncreasing
A watermark estimator that observes timestamps of records output from a DoFn reporting the timestamp of the last element seen as the current watermark.static class
WatermarkEstimators.WallTime
A watermark estimator that tracks wall time.
-