@Documented @Retention(value=RUNTIME) @Target(value=METHOD) @Experimental(value=SPLITTABLE_DO_FN) public static @interface DoFn.SplitRestriction
DoFn
into multiple parts to
be processed in parallel.
Signature: void splitRestriction(InputT element, RestrictionT restriction,
OutputReceiver<RestrictionT> receiver);
Optional: if this method is omitted, the restriction will not be split (equivalent to
defining the method and outputting the restriction
unchanged).