Package org.apache.beam.sdk.transforms

Annotation Interface DoFn.BoundedPerElement

Enclosing class:

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

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

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