@Experimental(value=SPLITTABLE_DO_FN) public class WatermarkEstimators extends java.lang.Object
WatermarkEstimator
s that users can use to advance the output watermark for their
associated splittable DoFn
s.Modifier and Type | Class and Description |
---|---|
static class |
WatermarkEstimators.Manual
Concrete implementation of a
ManualWatermarkEstimator . |
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.
|