org.apache.beam.sdk.transforms

Annotation Type DoFn.GetInitialRestriction

@Documented
 @Retention(value=RUNTIME)
 @Target(value=METHOD)
 @Experimental(value=SPLITTABLE_DO_FN)
public static @interface DoFn.GetInitialRestriction

Annotation for the method that maps an element to an initial restriction for a splittable DoFn.

Signature: RestrictionT getInitialRestriction(InputT element);

TODO: Make the InputT parameter optional.