org.apache.beam.sdk.transforms.splittabledofn

Interface TimestampObservingWatermarkEstimator<WatermarkEstimatorStateT>

All Superinterfaces:

WatermarkEstimator<WatermarkEstimatorStateT>

All Known Implementing Classes:

WatermarkEstimators.MonotonicallyIncreasing

@Experimental(value=SPLITTABLE_DO_FN)
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 and 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 Detail

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.