org.apache.spark.sql.streaming

Class StreamingQueryException

Object

Throwable

Exception

org.apache.spark.sql.streaming.StreamingQueryException

All Implemented Interfaces:

java.io.Serializable

public class StreamingQueryException
extends Exception

:: Experimental :: 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

Method Summary

Methods

Modifier and Type	Method and Description
Throwable	cause()
String	endOffset()
String	message()
String	startOffset()
long	time() Time when the exception occurred
String	toString()

Methods inherited from class Throwable

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

Methods inherited from class Object

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

Method Detail

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

toString

public String toString()

Overrides:

toString in class Throwable