Package org.apache.beam.sdk.transforms

Interface DoFn.BundleFinalizer.Callback

Enclosing interface:
DoFn.BundleFinalizer
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface DoFn.BundleFinalizer.Callback
An instance of a function that will be invoked after bundle finalization.

Note that this function should maintain all state necessary outside of a DoFn's context to be able to perform bundle finalization and should not rely on mutable state stored within a DoFn instance.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onBundleSuccess()
     

  • Method Details