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
.