Package org.apache.beam.sdk.fn.splittabledofn

Interface WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT>

All Superinterfaces:

WatermarkEstimator<WatermarkEstimatorStateT>

Enclosing class:

WatermarkEstimators

public static interface WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT>
extends WatermarkEstimator<WatermarkEstimatorStateT>

Interface which allows for accessing the current watermark and watermark estimator state.

Method Summary

Modifier and Type	Method	Description
KV<Instant,WatermarkEstimatorStateT>	getWatermarkAndState()

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

currentWatermark, getState

Method Details

getWatermarkAndState

KV<Instant,WatermarkEstimatorStateT> getWatermarkAndState()