All Implemented Interfaces:

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

• Method Summary

  cause()

  endOffset()

  Succinct, human-readable, unique, and consistent representation of the error condition.

  ================================================ Server side exceptions should override this method and use a provided SQL state property instead.

  message()

  long

  time()

  Time when the exception occurred

  toString()

  Methods inherited from class java.lang.Throwable

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

• Constructor Details

  • StreamingQueryException

    public StreamingQueryException(String queryDebugString, Throwable cause, String startOffset, String endOffset, String errorClass, scala.collection.immutable.Map<String,String> messageParameters)

• Method Details

  • message

  • cause

  • startOffset

    public String startOffset()

  • endOffset

    public String endOffset()

  • time

    public long time()

    Time when the exception occurred

  • getMessage

    public String getMessage()

    Overrides:

    getMessage in class Throwable

  • toString

    Overrides:

    toString in class Throwable

  • getCondition

    public String getCondition()

    Succinct, human-readable, unique, and consistent representation of the error condition. If null, error condition is not set.

    Specified by:

    getCondition in interface SparkThrowable

  • getSqlState

    public String getSqlState()

    ================================================ Server side exceptions should override this method and use a provided SQL state property instead. ================================================

    Specified by:

    getSqlState in interface SparkThrowable

  • getMessageParameters

    Specified by:

    getMessageParameters in interface SparkThrowable