org.apache.beam.runners.local

Interface PipelineMessageReceiver

public interface PipelineMessageReceiver

Handles failures in the form of exceptions.

Method Summary

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

Method Detail

failed

void failed(java.lang.Exception e)

Report that a failure has occurred.

failed

void failed(java.lang.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.