public interface HasDefaultWatermarkEstimator<WatermarkEstimatorStateT,WatermarkEstimatorT extends WatermarkEstimator<WatermarkEstimatorStateT>>
DoFn.NewWatermarkEstimator is available, depending only on the watermark estimator state itself.| Modifier and Type | Method and Description |
|---|---|
WatermarkEstimatorT |
newWatermarkEstimator()
Creates a new watermark estimator for
this. |
WatermarkEstimatorT newWatermarkEstimator()
this.