Package org.apache.beam.sdk.transforms

Annotation Interface DoFn.UnboundedPerElement

Enclosing class:

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

@Documented
@Retention(RUNTIME)
@Target(TYPE)
public static @interface DoFn.UnboundedPerElement

Annotation on a splittable DoFn specifying that the DoFn performs an unbounded amount of work per input element, so applying it to a bounded PCollection will produce an unbounded PCollection. It is an error to specify this on a non-splittable DoFn.