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

Class FailureStoppingOperation

Object

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

org.apache.spark.sql.pipelines.graph.FailureStoppingOperation

All Implemented Interfaces:

RunTerminationReason

Direct Known Subclasses:

FailureStoppingFlow

public abstract class FailureStoppingOperation
extends RunFailure

Abstract class used to identify failures related to failures stopping an operation/timeouts.

Constructor Summary

Constructors

Constructor	Description
FailureStoppingOperation()

Method Summary

Modifier and Type	Method	Description
abstract String	operation()	Name of the operation that failed to stop.

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

isFatal, terminalState

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

FailureStoppingOperation

public FailureStoppingOperation()

Method Details

operation

public abstract String operation()

Name of the operation that failed to stop.