Package org.apache.beam.sdk.transforms
Annotation Type DoFn.WatermarkEstimatorState
-
@Documented @Retention(RUNTIME) @Target(PARAMETER) public static @interface DoFn.WatermarkEstimatorState
Parameter annotation for the watermark estimator state for theDoFn.NewWatermarkEstimator
method. Must match the return type on the method annotated withDoFn.GetInitialWatermarkEstimatorState
.