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
ConstructorsConstructorDescriptionFailureStoppingFlow
(scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.TableIdentifier> flowIdentifiers) -
Method Summary
Modifier and TypeMethodDescriptionabstract 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>
boolean
isFatal()
Whether or not this failure is considered fatal / irrecoverable.message()
User visible message associated with run termination.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
-
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 classRunFailure
-
operation
Description copied from class:FailureStoppingOperation
Name of the operation that failed to stop.- Specified by:
operation
in classFailureStoppingOperation
-
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 interfaceRunTerminationReason
- Returns:
- (undocumented)
-
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 interfaceRunTerminationReason
- Returns:
- (undocumented)
-