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 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