public static interface WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT> extends WatermarkEstimator<WatermarkEstimatorStateT>
Modifier and Type | Method and Description |
---|---|
KV<Instant,WatermarkEstimatorStateT> |
getWatermarkAndState() |
currentWatermark, getState
KV<Instant,WatermarkEstimatorStateT> getWatermarkAndState()