org.apache.beam.sdk.transforms

Annotation Type DoFn.GetRestrictionCoder

@Documented
 @Retention(value=RUNTIME)
 @Target(value=METHOD)
public static @interface DoFn.GetRestrictionCoder

Annotation for the method that returns the coder to use for the restriction 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<RestrictionT> getRestrictionCoder();