Skip to content

[SPARK-36336][SQL][FOLLOWUP] Mark exception private[spark] #33856

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
Peng-Lei wants to merge 1 commit into from
Closed

[SPARK-36336][SQL][FOLLOWUP] Mark exception private[spark] #33856

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
40 changes: 28 additions & 12 deletions core/src/main/scala/org/apache/spark/SparkException.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ private[spark] class SparkArithmeticException(errorClass: String, messageParamet
/**
* Class not found exception thrown from Spark with an error class.
*/
class SparkClassNotFoundException(
private[spark] class SparkClassNotFoundException(
errorClass: String,
messageParameters: Array[String],
cause: Throwable = null)
Expand All @@ -104,7 +104,7 @@ class SparkClassNotFoundException(
/**
* Concurrent modification exception thrown from Spark with an error class.
*/
class SparkConcurrentModificationException(
private[spark] class SparkConcurrentModificationException(
errorClass: String,
messageParameters: Array[String],
cause: Throwable = null)
Expand All @@ -118,7 +118,7 @@ class SparkConcurrentModificationException(
/**
* Datetime exception thrown from Spark with an error class.
*/
class SparkDateTimeException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkDateTimeException(errorClass: String, messageParameters: Array[String])
extends DateTimeException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -129,7 +129,9 @@ class SparkDateTimeException(errorClass: String, messageParameters: Array[String
/**
* Hadoop file already exists exception thrown from Spark with an error class.
*/
class SparkFileAlreadyExistsException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkFileAlreadyExistsException(
errorClass: String,
messageParameters: Array[String])
extends FileAlreadyExistsException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -140,7 +142,9 @@ class SparkFileAlreadyExistsException(errorClass: String, messageParameters: Arr
/**
* File not found exception thrown from Spark with an error class.
*/
class SparkFileNotFoundException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkFileNotFoundException(
errorClass: String,
messageParameters: Array[String])
extends FileNotFoundException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -151,7 +155,9 @@ class SparkFileNotFoundException(errorClass: String, messageParameters: Array[St
/**
* No such method exception thrown from Spark with an error class.
*/
class SparkNoSuchMethodException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkNoSuchMethodException(
errorClass: String,
messageParameters: Array[String])
extends NoSuchMethodException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -162,7 +168,9 @@ class SparkNoSuchMethodException(errorClass: String, messageParameters: Array[St
/**
* Index out of bounds exception thrown from Spark with an error class.
*/
class SparkIndexOutOfBoundsException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkIndexOutOfBoundsException(
errorClass: String,
messageParameters: Array[String])
extends IndexOutOfBoundsException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -173,15 +181,17 @@ class SparkIndexOutOfBoundsException(errorClass: String, messageParameters: Arra
/**
* IO exception thrown from Spark with an error class.
*/
class SparkIOException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkIOException(
errorClass: String,
messageParameters: Array[String])
extends IOException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

override def getErrorClass: String = errorClass
override def getSqlState: String = SparkThrowableHelper.getSqlState(errorClass)
}

class SparkRuntimeException(
private[spark] class SparkRuntimeException(
errorClass: String,
messageParameters: Array[String],
cause: Throwable = null)
Expand All @@ -195,7 +205,9 @@ class SparkRuntimeException(
/**
* Security exception thrown from Spark with an error class.
*/
class SparkSecurityException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkSecurityException(
errorClass: String,
messageParameters: Array[String])
extends SecurityException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -206,7 +218,9 @@ class SparkSecurityException(errorClass: String, messageParameters: Array[String
/**
* SQL exception thrown from Spark with an error class.
*/
class SparkSQLException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkSQLException(
errorClass: String,
messageParameters: Array[String])
extends SQLException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand All @@ -217,7 +231,9 @@ class SparkSQLException(errorClass: String, messageParameters: Array[String])
/**
* SQL feature not supported exception thrown from Spark with an error class.
*/
class SparkSQLFeatureNotSupportedException(errorClass: String, messageParameters: Array[String])
private[spark] class SparkSQLFeatureNotSupportedException(
errorClass: String,
messageParameters: Array[String])
extends SQLFeatureNotSupportedException(
SparkThrowableHelper.getMessage(errorClass, messageParameters)) with SparkThrowable {

Expand Down