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

Interface BundleSplitHandler

public interface BundleSplitHandler
A handler which is invoked whenever an active bundle is split. The active bundle will continue to keep processing until it is complete.

The returned split response contains a description of work that has been performed containing a primary portion that the SDK is responsible for processing and a residual which the runner is responsible for scheduling for future processing. See breaking the fusion barrier for further details.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    split(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleSplitResponse splitResponse)
     
    static BundleSplitHandler
    unsupported()
    Returns a bundle split handler that throws on any split response.

  • Method Details

    • split

      void split(org.apache.beam.model.fnexecution.v1.BeamFnApi.ProcessBundleSplitResponse splitResponse)

    • unsupported

      static BundleSplitHandler unsupported()
      Returns a bundle split handler that throws on any split response.