Package org.apache.beam.runners.local

Interface PipelineMessageReceiver

public interface PipelineMessageReceiver
Handles failures in the form of exceptions.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    cancelled()
    Report that the pipeline has been cancelled.
    void
    completed()
    Report that the pipeline has successfully completed.
    void
    failed(Error e)
    Report that a failure has occurred.
    void
    failed(Exception e)
    Report that a failure has occurred.

  • Method Details

    • failed

      void failed(Exception e)
      Report that a failure has occurred.

    • failed

      void failed(Error e)
      Report that a failure has occurred.

    • cancelled

      void cancelled()
      Report that the pipeline has been cancelled.

    • completed

      void completed()
      Report that the pipeline has successfully completed.