case class UnresolvedPipelineException(graph: DataflowGraph, directFailures: Map[TableIdentifier, Throwable], downstreamFailures: Map[TableIdentifier, Throwable], additionalHint: Option[String] = None) extends AnalysisException with Product with Serializable
Exception raised when a pipeline has one or more flows that cannot be resolved
- 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
- 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
- Source
- PipelinesErrors.scala
- Alphabetic
- By Inheritance
- UnresolvedPipelineException
- Product
- Equals
- AnalysisException
- WithOrigin
- SparkThrowable
- Exception
- Throwable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new UnresolvedPipelineException(graph: DataflowGraph, directFailures: Map[TableIdentifier, Throwable], downstreamFailures: Map[TableIdentifier, Throwable], additionalHint: Option[String] = None)
- 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
- 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
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def addSuppressed(arg0: Throwable): Unit
- Definition Classes
- Throwable
- val additionalHint: Option[String]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val cause: Option[Throwable]
- Definition Classes
- AnalysisException
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val context: Array[spark.QueryContext]
- Definition Classes
- AnalysisException
- def copy(message: String = this.message, line: Option[Int] = this.line, startPosition: Option[Int] = this.startPosition, cause: Option[Throwable] = this.cause, errorClass: Option[String] = this.errorClass, messageParameters: Map[String, String] = this.messageParameters, context: Array[spark.QueryContext] = this.context, sqlState: Option[String] = this.sqlState, messageTemplate: Option[String] = this.messageTemplate): AnalysisException
- Definition Classes
- AnalysisException
- def copy(message: String, line: Option[Int], startPosition: Option[Int], cause: Option[Throwable], errorClass: Option[String], messageParameters: Map[String, String], context: Array[spark.QueryContext]): AnalysisException
- Definition Classes
- AnalysisException
- val directFailures: Map[TableIdentifier, Throwable]
- val downstreamFailures: Map[TableIdentifier, Throwable]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val errorClass: Option[String]
- Definition Classes
- AnalysisException
- def fillInStackTrace(): Throwable
- Definition Classes
- Throwable
- def getBreakingChangeInfo(): BreakingChangeInfo
- Definition Classes
- SparkThrowable
- def getCause(): Throwable
- Definition Classes
- Throwable
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getCondition(): String
Succinct, human-readable, unique, and consistent representation of the error condition.
Succinct, human-readable, unique, and consistent representation of the error condition. If null, error condition is not set.
- Definition Classes
- AnalysisException → SparkThrowable
- def getDefaultMessageTemplate(): String
Returns the default message template for this error.
Returns the default message template for this error.
The template is a machine-readable string with placeholders to be filled by
getMessageParameters().This is the default template known to Spark, but clients are free to generate their own messages (e.g., translations, alternate formats) using the provided error metadata.
- returns
the default message template for this error, or null if unavailable
- Definition Classes
- AnalysisException → SparkThrowable
- def getLocalizedMessage(): String
- Definition Classes
- Throwable
- def getMessage(): String
- Definition Classes
- AnalysisException → Throwable
- def getMessageParameters(): Map[String, String]
- Definition Classes
- AnalysisException → SparkThrowable
- def getQueryContext(): Array[spark.QueryContext]
- Definition Classes
- AnalysisException → SparkThrowable
- def getSimpleMessage: String
- Definition Classes
- AnalysisException
- def getSqlState(): String
- Definition Classes
- AnalysisException → SparkThrowable
- def getStackTrace(): Array[StackTraceElement]
- Definition Classes
- Throwable
- final def getSuppressed(): Array[Throwable]
- Definition Classes
- Throwable
- val graph: DataflowGraph
- def initCause(arg0: Throwable): Throwable
- Definition Classes
- Throwable
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isInternalError(): Boolean
- Definition Classes
- SparkThrowable
- val line: Option[Int]
- Definition Classes
- AnalysisException
- val message: String
- Definition Classes
- AnalysisException
- val messageParameters: Map[String, String]
- Definition Classes
- AnalysisException
- val messageTemplate: Option[String]
- Definition Classes
- AnalysisException
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- lazy val origin: Origin
- Definition Classes
- AnalysisException → WithOrigin
- def printStackTrace(arg0: PrintWriter): Unit
- Definition Classes
- Throwable
- def printStackTrace(arg0: PrintStream): Unit
- Definition Classes
- Throwable
- def printStackTrace(): Unit
- Definition Classes
- Throwable
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def setStackTrace(arg0: Array[StackTraceElement]): Unit
- Definition Classes
- Throwable
- val sqlState: Option[String]
- Definition Classes
- AnalysisException
- val startPosition: Option[Int]
- Definition Classes
- AnalysisException
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- Throwable → AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def withPosition(origin: Origin): AnalysisException
- Definition Classes
- AnalysisException
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def getErrorClass(): String
Succinct, human-readable, unique, and consistent representation of the error category.
Succinct, human-readable, unique, and consistent representation of the error category. If null, error class is not set.
- Definition Classes
- SparkThrowable
- Annotations
- @Deprecated
- Deprecated