public interface TimestampObservingWatermarkEstimator<WatermarkEstimatorStateT> extends WatermarkEstimator<WatermarkEstimatorStateT>
WatermarkEstimator
that observes the timestamps of all records output from a DoFn
.Modifier and Type | Method and Description |
---|---|
void |
observeTimestamp(Instant timestamp)
Update watermark estimate with latest output timestamp.
|
currentWatermark, getState
void observeTimestamp(Instant timestamp)