Packages

c

org.apache.spark.sql.streaming

StreamingQueryException

class StreamingQueryException extends Exception with SparkThrowable

Exception that stopped a StreamingQuery. Use cause get the actual exception that caused the failure.

Annotations
@Evolving()
Source
StreamingQueryException.scala
Since

2.0.0

Linear Supertypes
SparkThrowable, Exception, Throwable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamingQueryException
  2. SparkThrowable
  3. Exception
  4. Throwable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new StreamingQueryException(queryDebugString: String, cause: Throwable, startOffset: String, endOffset: String, errorClass: String, messageParameters: Map[String, String])

Value Members

  1. final def addSuppressed(arg0: Throwable): Unit
    Definition Classes
    Throwable
  2. val cause: Throwable
  3. val endOffset: String
  4. def fillInStackTrace(): Throwable
    Definition Classes
    Throwable
  5. def getCause(): Throwable
    Definition Classes
    Throwable
  6. def getErrorClass(): String
    Definition Classes
    StreamingQueryException → SparkThrowable
  7. def getLocalizedMessage(): String
    Definition Classes
    Throwable
  8. def getMessage(): String
    Definition Classes
    StreamingQueryException → Throwable
  9. def getMessageParameters(): Map[String, String]
    Definition Classes
    StreamingQueryException → SparkThrowable
  10. def getQueryContext(): Array[QueryContext]
    Definition Classes
    SparkThrowable
  11. def getSqlState(): String
    Definition Classes
    SparkThrowable
  12. def getStackTrace(): Array[StackTraceElement]
    Definition Classes
    Throwable
  13. final def getSuppressed(): Array[Throwable]
    Definition Classes
    Throwable
  14. def initCause(arg0: Throwable): Throwable
    Definition Classes
    Throwable
  15. def isInternalError(): Boolean
    Definition Classes
    SparkThrowable
  16. val message: String
  17. def printStackTrace(arg0: PrintWriter): Unit
    Definition Classes
    Throwable
  18. def printStackTrace(arg0: PrintStream): Unit
    Definition Classes
    Throwable
  19. def printStackTrace(): Unit
    Definition Classes
    Throwable
  20. def setStackTrace(arg0: Array[StackTraceElement]): Unit
    Definition Classes
    Throwable
  21. val startOffset: String
  22. val time: Long

    Time when the exception occurred

  23. def toString(): String
    Definition Classes
    StreamingQueryException → Throwable → AnyRef → Any