Annotation Type DoFn.FinishBundle


  • @Documented
    @Retention(RUNTIME)
    @Target(METHOD)
    public static @interface DoFn.FinishBundle
    Annotation for the method to use to finish processing a batch of elements. The method annotated with this must satisfy the following constraints:

    Note that @FinishBundle is invoked before the runner commits the output while bundle finalizer callbacks are invoked after the runner has committed the output of a successful bundle.