Package org.apache.beam.sdk.transforms

Annotation Interface DoFn.WatermarkEstimatorState

Enclosing class:

DoFn<InputT extends @Nullable Object,OutputT extends @Nullable Object>

@Documented
@Retention(RUNTIME)
@Target(PARAMETER)
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.