org.apache.beam.sdk.transforms

Annotation Type DoFn.WatermarkEstimatorState

@Documented
 @Retention(value=RUNTIME)
 @Target(value=PARAMETER)
 @Experimental(value=SPLITTABLE_DO_FN)
public static @interface DoFn.WatermarkEstimatorState

Parameter annotation for the watermark estimator state for the DoFn.NewWatermarkEstimator method. Must match the return type on the method annotated with DoFn.GetInitialWatermarkEstimatorState.