Package org.apache.beam.sdk.transforms.splittabledofn

Interface TimestampObservingWatermarkEstimator<WatermarkEstimatorStateT>

All Superinterfaces:

WatermarkEstimator<WatermarkEstimatorStateT>

All Known Implementing Classes:

WatermarkEstimators.MonotonicallyIncreasing

public interface TimestampObservingWatermarkEstimator<WatermarkEstimatorStateT>
extends WatermarkEstimator<WatermarkEstimatorStateT>

A WatermarkEstimator that observes the timestamps of all records output from a DoFn.

Method Summary

Modifier and Type	Method	Description
void	observeTimestamp(Instant timestamp)	Update watermark estimate with latest output timestamp.

Methods inherited from interface org.apache.beam.sdk.transforms.splittabledofn.WatermarkEstimator

currentWatermark, getState

Method Details

observeTimestamp

void observeTimestamp(Instant timestamp)

Update watermark estimate with latest output timestamp. This is called with the timestamp of every element output from the DoFn.