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	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, getSqlState, 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

cause

public Throwable cause()

endOffset

public String endOffset()

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

getMessage

public String getMessage()

Overrides:

getMessage in class Throwable

getMessageParameters

public Map<String,String> getMessageParameters()

Specified by:

getMessageParameters in interface SparkThrowable

message

public String message()

startOffset

public String startOffset()

time

public long time()

Time when the exception occurred

toString

public String toString()

Overrides:

toString in class Throwable