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

Class DataflowGraphTransformer.TransformNodeRetryableException

Object

Throwable

Exception

org.apache.spark.sql.pipelines.graph.DataflowGraphTransformer.TransformNodeRetryableException

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product, scala.util.control.NoStackTrace

Enclosing class:

DataflowGraphTransformer

public static class DataflowGraphTransformer.TransformNodeRetryableException
extends Exception
implements scala.util.control.NoStackTrace, scala.Product, Serializable

Exception thrown when transforming a node in the graph fails because at least one of its dependencies weren't yet transformed.

param: datasetIdentifier The identifier for an untransformed dependency table identifier in the dataflow graph.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
TransformNodeRetryableException(org.apache.spark.sql.catalyst.TableIdentifier datasetIdentifier, ResolutionFailedFlow failedNode)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.sql.catalyst.TableIdentifier	datasetIdentifier()
ResolutionFailedFlow	failedNode()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.util.control.NoStackTrace

fillInStackTrace

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

TransformNodeRetryableException

public TransformNodeRetryableException(org.apache.spark.sql.catalyst.TableIdentifier datasetIdentifier,
 ResolutionFailedFlow failedNode)

Method Details

datasetIdentifier

public org.apache.spark.sql.catalyst.TableIdentifier datasetIdentifier()

failedNode

public ResolutionFailedFlow failedNode()