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

Class WatermarkEstimators

java.lang.Object

org.apache.beam.sdk.fn.splittabledofn.WatermarkEstimators

public class WatermarkEstimators
extends Object

Support utilties for interacting with WatermarkEstimators.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT>	Interface which allows for accessing the current watermark and watermark estimator state.

Constructor Summary

Constructors

Constructor	Description
WatermarkEstimators()

Method Summary

Modifier and Type	Method	Description
static <WatermarkEstimatorStateT> WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT>	threadSafe(WatermarkEstimator<WatermarkEstimatorStateT> watermarkEstimator)	Returns a thread safe WatermarkEstimator which allows getting a snapshot of the current watermark and watermark estimator state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WatermarkEstimators

public WatermarkEstimators()

Method Details

threadSafe

public static <WatermarkEstimatorStateT>
WatermarkEstimators.WatermarkAndStateObserver<WatermarkEstimatorStateT> threadSafe(WatermarkEstimator<WatermarkEstimatorStateT> watermarkEstimator)

Returns a thread safe WatermarkEstimator which allows getting a snapshot of the current watermark and watermark estimator state.