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 Details

    • FailureStoppingOperation

      public FailureStoppingOperation()
  • Method Details

    • operation

      public abstract String operation()
      Name of the operation that failed to stop.