org.apache.spark.sql

Class AnalysisException

Object

Throwable

Exception

org.apache.spark.sql.AnalysisException

All Implemented Interfaces:

java.io.Serializable, SparkThrowable

public class AnalysisException
extends Exception
implements SparkThrowable, scala.Serializable

Thrown when a query fails to analyze, usually because the query itself is invalid.

Since:

1.3.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AnalysisException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters)
AnalysisException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, scala.Option<Throwable> cause)
AnalysisException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, org.apache.spark.sql.catalyst.trees.Origin origin)
AnalysisException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, org.apache.spark.sql.catalyst.trees.Origin origin, scala.Option<Throwable> cause)
AnalysisException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, QueryContext[] context, String summary)

Method Summary

Modifier and Type	Method and Description
scala.Option<Throwable>	cause()
QueryContext[]	context()
AnalysisException	copy(String message, scala.Option<Object> line, scala.Option<Object> startPosition, scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> plan, scala.Option<Throwable> cause, scala.Option<String> errorClass, scala.collection.immutable.Map<String,String> messageParameters, QueryContext[] context)
scala.Option<String>	errorClass()
String	getErrorClass()
String	getMessage()
java.util.Map<String,String>	getMessageParameters()
QueryContext[]	getQueryContext()
String	getSimpleMessage()
scala.Option<Object>	line()
String	message()
scala.collection.immutable.Map<String,String>	messageParameters()
scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>	plan()
scala.Option<Object>	startPosition()
AnalysisException	withPosition(org.apache.spark.sql.catalyst.trees.Origin origin)

Methods inherited from class Throwable

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

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.SparkThrowable

getSqlState, isInternalError

Constructor Detail

AnalysisException

public AnalysisException(String errorClass,
                         scala.collection.immutable.Map<String,String> messageParameters,
                         scala.Option<Throwable> cause)

AnalysisException

public AnalysisException(String errorClass,
                         scala.collection.immutable.Map<String,String> messageParameters,
                         QueryContext[] context,
                         String summary)

AnalysisException

public AnalysisException(String errorClass,
                         scala.collection.immutable.Map<String,String> messageParameters)

AnalysisException

public AnalysisException(String errorClass,
                         scala.collection.immutable.Map<String,String> messageParameters,
                         org.apache.spark.sql.catalyst.trees.Origin origin)

AnalysisException

public AnalysisException(String errorClass,
                         scala.collection.immutable.Map<String,String> messageParameters,
                         org.apache.spark.sql.catalyst.trees.Origin origin,
                         scala.Option<Throwable> cause)

Method Detail

message

public String message()

line

public scala.Option<Object> line()

startPosition

public scala.Option<Object> startPosition()

plan

public scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> plan()

cause

public scala.Option<Throwable> cause()

errorClass

public scala.Option<String> errorClass()

messageParameters

public scala.collection.immutable.Map<String,String> messageParameters()

context

public QueryContext[] context()

copy

public AnalysisException copy(String message,
                              scala.Option<Object> line,
                              scala.Option<Object> startPosition,
                              scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> plan,
                              scala.Option<Throwable> cause,
                              scala.Option<String> errorClass,
                              scala.collection.immutable.Map<String,String> messageParameters,
                              QueryContext[] context)

withPosition

public AnalysisException withPosition(org.apache.spark.sql.catalyst.trees.Origin origin)

getMessage

public String getMessage()

Overrides:

getMessage in class Throwable

getSimpleMessage

public String getSimpleMessage()

getMessageParameters

public java.util.Map<String,String> getMessageParameters()

Specified by:

getMessageParameters in interface SparkThrowable

getErrorClass

public String getErrorClass()

Specified by:

getErrorClass in interface SparkThrowable

getQueryContext

public QueryContext[] getQueryContext()

Specified by:

getQueryContext in interface SparkThrowable