Package org.apache.beam.sdk.transforms
Annotation Type DoFn.GetWatermarkEstimatorStateCoder
-
@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 splittableDoFn
.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();