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

Class FailureStoppingFlow

Object
org.apache.spark.sql.pipelines.graph.RunFailure
org.apache.spark.sql.pipelines.graph.FailureStoppingOperation
org.apache.spark.sql.pipelines.graph.FailureStoppingFlow
All Implemented Interfaces:
Serializable, RunTerminationReason, scala.Equals, scala.Product
public class FailureStoppingFlow extends FailureStoppingOperation implements scala.Product, Serializable
Indicates that there was a failure while stopping the flow.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    FailureStoppingFlow(scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.TableIdentifier> flowIdentifiers)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract static R
    apply(T1 v1)
     
    scala.Option<Throwable>
    cause()
    Exception associated with the given run termination.
    scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.TableIdentifier>
    flowIdentifiers()
     
    boolean
    isFatal()
    Whether or not this failure is considered fatal / irrecoverable.
    String
    message()
    User visible message associated with run termination.
    String
    operation()
    Name of the operation that failed to stop.
    static String
    toString()
     

    Methods inherited from class org.apache.spark.sql.pipelines.graph.RunFailure

    terminalState

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface scala.Equals

    canEqual, equals

    Methods inherited from interface scala.Product

    productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

  • Constructor Details

    • FailureStoppingFlow

      public FailureStoppingFlow(scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.TableIdentifier> flowIdentifiers)

  • Method Details

    • apply

      public abstract static R apply(T1 v1)

    • toString

      public static String toString()

    • flowIdentifiers

      public scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.TableIdentifier> flowIdentifiers()

    • isFatal

      public boolean isFatal()
      Description copied from class: RunFailure
      Whether or not this failure is considered fatal / irrecoverable.
      Specified by:
      isFatal in class RunFailure

    • operation

      public String operation()
      Description copied from class: FailureStoppingOperation
      Name of the operation that failed to stop.
      Specified by:
      operation in class FailureStoppingOperation

    • message

      public String message()
      Description copied from interface: RunTerminationReason
      User visible message associated with run termination. This will also be set as the message in the associated terminal run progress log.
      Specified by:
      message in interface RunTerminationReason
      Returns:
      (undocumented)

    • cause

      public scala.Option<Throwable> cause()
      Description copied from interface: RunTerminationReason
      Exception associated with the given run termination. This exception will be included in the error details in the associated terminal run progress event.
      Specified by:
      cause in interface RunTerminationReason
      Returns:
      (undocumented)