public static class WatermarkEstimators.Manual extends java.lang.Object implements ManualWatermarkEstimator<Instant>
|Modifier and Type||Method and Description|
Return estimated output watermark.
Get current state of the
Sets a timestamp before or at the timestamps of all future elements produced by the associated DoFn.
public Manual(Instant watermark)
public void setWatermark(Instant watermark)
This can be approximate. If records are output that violate this guarantee, they will be considered late, which will affect how they will be processed. See watermarks and late data for more information on late data and how to handle it.
However, this value should be as late as possible. Downstream windows may not be able to close until this watermark passes their end.
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.