HasDefaultWatermarkEstimator (Apache Beam 2.23.0)

@Experimental(value=SPLITTABLE_DO_FN)
public interface HasDefaultWatermarkEstimator<WatermarkEstimatorStateT,WatermarkEstimatorT extends WatermarkEstimator<WatermarkEstimatorStateT>>

Interface for watermark estimator state for which a default implementation of DoFn.NewWatermarkEstimator is available, depending only on the watermark estimator state itself.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method and Description
  
  WatermarkEstimatorT newWatermarkEstimator()
  Creates a new watermark estimator for this.

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`WatermarkEstimatorT`	`newWatermarkEstimator()` Creates a new watermark estimator for `this`.

- Method Detail
  - newWatermarkEstimator
```
WatermarkEstimatorT newWatermarkEstimator()
```
    Creates a new watermark estimator for this.

Interface HasDefaultWatermarkEstimator<WatermarkEstimatorStateT,WatermarkEstimatorT extends WatermarkEstimator<WatermarkEstimatorStateT>>

Method Summary

Method Detail

newWatermarkEstimator