public static class WatermarkEstimators.WallTime extends java.lang.Object implements WatermarkEstimator<Instant>
Note that this watermark estimator expects wall times of all machines performing the processing to be close to each other. Any machine with a wall clock that is far in the past may cause the pipeline to perform poorly while a watermark far in the future may cause records to be marked as late.
|Modifier and Type||Method and Description|
Return estimated output watermark.
Get current state of the
public WallTime(Instant watermark)
public Instant currentWatermark()
public Instant getState()
WatermarkEstimatorinstance, which can be used to recreate the
WatermarkEstimatorwhen processing the restriction. See
DoFn.NewWatermarkEstimatorfor additional details.
The internal state of the estimator must not be mutated by this method.
The state returned must not be mutated.