Package org.apache.spark.sql.pipelines.graph

Class RunFailure

Object

org.apache.spark.sql.pipelines.graph.RunFailure

All Implemented Interfaces:

RunTerminationReason

Direct Known Subclasses:

FailureStoppingOperation, QueryExecutionFailure, UnexpectedRunFailure

public abstract class RunFailure
extends Object
implements RunTerminationReason

Indicates that an run entered the failed state..

Constructor Summary

Constructors

Constructor	Description
RunFailure()

Method Summary

Modifier and Type	Method	Description
abstract boolean	isFatal()	Whether or not this failure is considered fatal / irrecoverable.
RunState	terminalState()	Terminal state for the given run.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.pipelines.graph.RunTerminationReason

cause, message

Constructor Details

RunFailure

public RunFailure()

Method Details

isFatal

public abstract boolean isFatal()

Whether or not this failure is considered fatal / irrecoverable.

terminalState

public RunState terminalState()

Description copied from interface: RunTerminationReason

Terminal state for the given run.

Specified by:

terminalState in interface RunTerminationReason