Object

Throwable

Exception

org.apache.spark.SparkException

All Implemented Interfaces:: Serializable, SparkThrowable

Direct Known Subclasses:: CatalogNotFoundException, UnrecognizedBlockId

public class SparkException extends Exception implements SparkThrowable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor

Description

SparkException(String message)

SparkException(String message, Throwable cause)

SparkException(String message, Throwable cause, scala.Option<String> errorClass, scala.collection.immutable.Map<String,String> messageParameters, QueryContext[] context)

SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause)

SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause, QueryContext[] context)

SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause, QueryContext[] context, String summary)
Method Summary

Modifier and Type

Method

Description

static scala.collection.immutable.Map<String,String>

constructMessageParams(Map<String,String> messageParameters)

Utility method to construct message params from Java Map.

String

getCondition()

Succinct, human-readable, unique, and consistent representation of the error condition.

Map<String,String>

getMessageParameters()

QueryContext[]

getQueryContext()

static SparkException

internalError(String msg)

static SparkException

internalError(String msg, String category)

static SparkException

internalError(String msg, Throwable cause)

static SparkException

internalError(String msg, QueryContext[] context, String summary)

static SparkException

internalError(String msg, QueryContext[] context, String summary, scala.Option<String> category)

static void

require(boolean requirement, String errorClass, scala.Function0<scala.collection.immutable.Map<String,String>> messageParameters)

This is like the Scala require precondition, except it uses SparkIllegalArgumentException.

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 org.apache.spark.SparkThrowable
getErrorClass, getSqlState, isInternalError

Constructor Details
- SparkException
  
  public SparkException(String message, Throwable cause, scala.Option<String> errorClass, scala.collection.immutable.Map<String,String> messageParameters, QueryContext[] context)
- SparkException
  
  public SparkException(String message, Throwable cause)
- SparkException
  
  public SparkException(String message)
- SparkException
  
  public SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause, QueryContext[] context, String summary)
- SparkException
  
  public SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause)
- SparkException
  
  public SparkException(String errorClass, scala.collection.immutable.Map<String,String> messageParameters, Throwable cause, QueryContext[] context)
Method Details
- internalError
  
  public static SparkException internalError(String msg, QueryContext[] context, String summary)
- internalError
  
  public static SparkException internalError(String msg, QueryContext[] context, String summary, scala.Option<String> category)
- internalError
  
  public static SparkException internalError(String msg)
- internalError
  
  public static SparkException internalError(String msg, String category)
- internalError
  
  public static SparkException internalError(String msg, Throwable cause)
- require
  
  public static void require(boolean requirement, String errorClass, scala.Function0<scala.collection.immutable.Map<String,String>> messageParameters)
  
  This is like the Scala require precondition, except it uses SparkIllegalArgumentException.
  
  Parameters:
  
  requirement - The requirement you want to check
  
  errorClass - The error class to type if the requirement isn't passed
  
  messageParameters - Message parameters to append to the message
- constructMessageParams
  
  public static scala.collection.immutable.Map<String,String> constructMessageParams(Map<String,String> messageParameters)
  
  Utility method to construct message params from Java Map.
  
  Parameters:
  
  messageParameters - The Java Map.
  
  Returns:
  
  Scala collection that can be passed to SparkException constructor.
- getMessageParameters
  
  public Map<String,String> getMessageParameters()
  
  Specified by:
  
  getMessageParameters in interface SparkThrowable
- getCondition
  
  public String getCondition()
  
  Description copied from interface: SparkThrowable
  
  Succinct, human-readable, unique, and consistent representation of the error condition. If null, error condition is not set.
  
  Specified by:
  
  getCondition in interface SparkThrowable
- getQueryContext
  
  public QueryContext[] getQueryContext()
  
  Specified by:
  
  getQueryContext in interface SparkThrowable

Class SparkException

Constructor Summary

Method Summary

Methods inherited from class java.lang.Throwable

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.spark.SparkThrowable

Constructor Details

SparkException

SparkException

SparkException

SparkException

SparkException

SparkException

Method Details

internalError

internalError

internalError

internalError

internalError

require

constructMessageParams

getMessageParameters

getCondition

getQueryContext