public interface ManualWatermarkEstimator<WatermarkEstimatorStateT> extends WatermarkEstimator<WatermarkEstimatorStateT>
WatermarkEstimatorwhich is controlled manually from within a
setWatermark(org.joda.time.Instant)to advance the watermark. See
WatermarkEstimators.Manualfor a concrete implementation.
|Modifier and Type||Method and Description|
Sets a timestamp before or at the timestamps of all future elements produced by the associated DoFn.
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.