Package org.apache.spark.sql.streaming

Class StreamingQueryException

Object

Throwable

Exception

org.apache.spark.sql.streaming.StreamingQueryException

All Implemented Interfaces:

Serializable, SparkThrowable

public class StreamingQueryException
extends Exception
implements SparkThrowable

Exception that stopped a StreamingQuery. Use cause get the actual exception that caused the failure. param: message Message of this exception param: cause Internal cause of this exception param: startOffset Starting offset in json of the range of data in which exception occurred param: endOffset Ending offset in json of the range of data in exception occurred

Since:

2.0.0

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamingQueryException(String queryDebugString, Throwable cause, String startOffset, String endOffset, String errorClass, scala.collection.immutable.Map<String,String> messageParameters)

Method Summary

Modifier and Type	Method	Description
Throwable	cause()
String	endOffset()
String	getCondition()	Succinct, human-readable, unique, and consistent representation of the error condition.
String	getMessage()
Map<String,String>	getMessageParameters()
String	getSqlState()	================================================ Server side exceptions should override this method and use a provided SQL state property instead.
String	message()
String	startOffset()
long	time()	Time when the exception occurred
String	toString()

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.SparkThrowable

getBreakingChangeInfo, getDefaultMessageTemplate, getErrorClass, getQueryContext, isInternalError

Constructor Details

StreamingQueryException

public StreamingQueryException(String queryDebugString,
 Throwable cause,
 String startOffset,
 String endOffset,
 String errorClass,
 scala.collection.immutable.Map<String,String> messageParameters)

Method Details

message

public String message()

cause

public Throwable cause()

startOffset

public String startOffset()

endOffset

public String endOffset()

time

public long time()

Time when the exception occurred

getMessage

public String getMessage()

Overrides:

getMessage in class Throwable

toString

public String toString()

Overrides:

toString in class Throwable

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

getSqlState

public String getSqlState()

Description copied from interface: SparkThrowable

================================================ Server side exceptions should override this method and use a provided SQL state property instead. ================================================

Specified by:

getSqlState in interface SparkThrowable

getMessageParameters

public Map<String,String> getMessageParameters()

Specified by:

getMessageParameters in interface SparkThrowable