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

Class UnresolvedPipelineException

Object

Throwable

Exception

org.apache.spark.sql.AnalysisException

org.apache.spark.sql.pipelines.graph.UnresolvedPipelineException

All Implemented Interfaces:

Serializable, SparkThrowable, org.apache.spark.sql.catalyst.trees.WithOrigin, scala.Equals, scala.Product

public class UnresolvedPipelineException
extends AnalysisException
implements scala.Product, Serializable

Exception raised when a pipeline has one or more flows that cannot be resolved

param: directFailures Mapping between the name of flows that failed to resolve (due to an error in that flow) and the error that occurred when attempting to resolve them param: downstreamFailures Mapping between the name of flows that failed to resolve (because they failed to read from other unresolved flows) and the error that occurred when attempting to resolve them

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
UnresolvedPipelineException(DataflowGraph graph, scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> directFailures, scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> downstreamFailures, scala.Option<String> additionalHint)

Method Summary

Modifier and Type	Method	Description
scala.Option<String>	additionalHint()
abstract static R	apply(T1 v1, T2 v2, T3 v3, T4 v4)
scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable>	directFailures()
scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable>	downstreamFailures()
DataflowGraph	graph()
static String	toString()

Methods inherited from class org.apache.spark.sql.AnalysisException

cause, context, copy, errorClass, getCondition, getMessage, getMessageParameters, getQueryContext, getSimpleMessage, line, message, messageParameters, origin, startPosition, withPosition

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, 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.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface org.apache.spark.SparkThrowable

getErrorClass, getSqlState, isInternalError

Constructor Details

UnresolvedPipelineException

public UnresolvedPipelineException(DataflowGraph graph,
 scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> directFailures,
 scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> downstreamFailures,
 scala.Option<String> additionalHint)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2,
 T3 v3,
 T4 v4)

toString

public static String toString()

graph

public DataflowGraph graph()

directFailures

public scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> directFailures()

downstreamFailures

public scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Throwable> downstreamFailures()

additionalHint

public scala.Option<String> additionalHint()