org.apache.spark.sql

Class ContinuousQueryException

java.lang.Object

java.lang.Throwable

java.lang.Exception

org.apache.spark.sql.ContinuousQueryException

All Implemented Interfaces:

java.io.Serializable

public class ContinuousQueryException
extends java.lang.Exception

:: Experimental :: Exception that stopped a ContinuousQuery. param: query Query that caused the exception param: message Message of this exception param: cause Internal cause of this exception param: startOffset Starting offset (if known) of the range of data in which exception occurred param: endOffset Ending offset (if known) 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
static void	addSuppressed(java.lang.Throwable x$1)
java.lang.Throwable	cause()
scala.Option<org.apache.spark.sql.execution.streaming.Offset>	endOffset()
static java.lang.Throwable	fillInStackTrace()
static java.lang.Throwable	getCause()
static java.lang.String	getLocalizedMessage()
static java.lang.String	getMessage()
static java.lang.StackTraceElement[]	getStackTrace()
static java.lang.Throwable[]	getSuppressed()
static java.lang.Throwable	initCause(java.lang.Throwable x$1)
java.lang.String	message()
static void	printStackTrace()
static void	printStackTrace(java.io.PrintStream x$1)
static void	printStackTrace(java.io.PrintWriter x$1)
ContinuousQuery	query()
static void	setStackTrace(java.lang.StackTraceElement[] x$1)
scala.Option<org.apache.spark.sql.execution.streaming.Offset>	startOffset()
long	time() Time when the exception occurred
java.lang.String	toString()

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getMessage

public static java.lang.String getMessage()

getLocalizedMessage

public static java.lang.String getLocalizedMessage()

getCause

public static java.lang.Throwable getCause()

initCause

public static java.lang.Throwable initCause(java.lang.Throwable x$1)

printStackTrace

public static void printStackTrace()

printStackTrace

public static void printStackTrace(java.io.PrintStream x$1)

printStackTrace

public static void printStackTrace(java.io.PrintWriter x$1)

fillInStackTrace

public static java.lang.Throwable fillInStackTrace()

getStackTrace

public static java.lang.StackTraceElement[] getStackTrace()

setStackTrace

public static void setStackTrace(java.lang.StackTraceElement[] x$1)

addSuppressed

public static final void addSuppressed(java.lang.Throwable x$1)

getSuppressed

public static final java.lang.Throwable[] getSuppressed()

query

public ContinuousQuery query()

message

public java.lang.String message()

cause

public java.lang.Throwable cause()

startOffset

public scala.Option<org.apache.spark.sql.execution.streaming.Offset> startOffset()

endOffset

public scala.Option<org.apache.spark.sql.execution.streaming.Offset> endOffset()

time

public long time()

Time when the exception occurred

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Throwable