Interface HasDefaultWatermarkEstimator<WatermarkEstimatorStateT,WatermarkEstimatorT extends WatermarkEstimator<WatermarkEstimatorStateT>>
-
public interface HasDefaultWatermarkEstimator<WatermarkEstimatorStateT,WatermarkEstimatorT extends WatermarkEstimator<WatermarkEstimatorStateT>>Interface for watermark estimator state for which a default implementation ofDoFn.NewWatermarkEstimatoris available, depending only on the watermark estimator state itself.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description WatermarkEstimatorTnewWatermarkEstimator()Creates a new watermark estimator forthis.
-
-
-
Method Detail
-
newWatermarkEstimator
WatermarkEstimatorT newWatermarkEstimator()
Creates a new watermark estimator forthis.
-
-