Package org.apache.beam.sdk.transforms

Annotation Interface DoFn.GetWatermarkEstimatorStateCoder

Enclosing class:

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

@Documented
@Retention(RUNTIME)
@Target(METHOD)
public static @interface DoFn.GetWatermarkEstimatorStateCoder

Annotation for the method that returns the coder to use for the watermark estimator state of a splittable DoFn.

If not defined, a coder will be inferred using standard coder inference rules and the pipeline's coder registry.

This method will be called only at pipeline construction time.

Signature: Coder<WatermarkEstimatorStateT> getWatermarkEstimatorStateCoder();