Package org.apache.beam.sdk.transforms.splittabledofn

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 of DoFn.NewWatermarkEstimator is available, depending only on the watermark estimator state itself.

  • Method Details

    • newWatermarkEstimator

      WatermarkEstimatorT newWatermarkEstimator()
      Creates a new watermark estimator for this.