public class StreamingQueryException
extends Exception
StreamingQuery
. Use cause
get the actual exception
that caused the failure.
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 occurredModifier and Type | Method and Description |
---|---|
static void |
addSuppressed(Throwable x$1) |
Throwable |
cause() |
scala.Option<org.apache.spark.sql.execution.streaming.Offset> |
endOffset() |
static Throwable |
fillInStackTrace() |
static Throwable |
getCause() |
static String |
getLocalizedMessage() |
static String |
getMessage() |
static StackTraceElement[] |
getStackTrace() |
static Throwable[] |
getSuppressed() |
static Throwable |
initCause(Throwable x$1) |
String |
message() |
static void |
printStackTrace() |
static void |
printStackTrace(java.io.PrintStream x$1) |
static void |
printStackTrace(java.io.PrintWriter x$1) |
StreamingQuery |
query() |
static void |
setStackTrace(StackTraceElement[] x$1) |
scala.Option<org.apache.spark.sql.execution.streaming.Offset> |
startOffset() |
long |
time()
Time when the exception occurred
|
String |
toString() |
public static String getMessage()
public static String getLocalizedMessage()
public static Throwable getCause()
public static Throwable initCause(Throwable x$1)
public static void printStackTrace()
public static void printStackTrace(java.io.PrintStream x$1)
public static void printStackTrace(java.io.PrintWriter x$1)
public static Throwable fillInStackTrace()
public static StackTraceElement[] getStackTrace()
public static void setStackTrace(StackTraceElement[] x$1)
public static final void addSuppressed(Throwable x$1)
public static final Throwable[] getSuppressed()
public StreamingQuery query()
public String message()
public Throwable cause()
public scala.Option<org.apache.spark.sql.execution.streaming.Offset> startOffset()
public scala.Option<org.apache.spark.sql.execution.streaming.Offset> endOffset()
public long time()
public String toString()
toString
in class Throwable