Package org.apache.beam.runners.fnexecution.control

Interface BundleProgressHandler

public interface BundleProgressHandler
A handler for bundle progress messages, both during bundle execution and on its completion.

Methods on this interface will only be called serially, and after onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse) no more calls will be made.

  • Method Summary

    Modifier and Type
    Method
    Description
    static BundleProgressHandler
    ignored()
    Returns a handler that ignores metrics.
    void
    onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
    Handles the bundle's completion report.
    void
    onProgress(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleProgressResponse progress)
    Handles a progress report from the bundle while it is executing.

  • Method Details

    • onProgress

      void onProgress(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleProgressResponse progress)
      Handles a progress report from the bundle while it is executing.

    • onCompleted

      void onCompleted(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleResponse response)
      Handles the bundle's completion report.

    • ignored

      static BundleProgressHandler ignored()
      Returns a handler that ignores metrics.