Class StreamingQueryListener.QueryTerminatedEvent

All Implemented Interfaces:
Serializable, SparkListenerEvent, StreamingQueryListener.Event, scala.Serializable
Enclosing class:

public static class StreamingQueryListener.QueryTerminatedEvent extends Object implements StreamingQueryListener.Event, scala.Serializable
Event representing that termination of a query.

param: id A unique query id that persists across restarts. See param: runId A query id that is unique for every start/restart. See StreamingQuery.runId(). param: exception The exception message of the query if the query was terminated with an exception. Otherwise, it will be None. param: errorClassOnException The error class from the exception if the query was terminated with an exception which is a part of error class framework. If the query was terminated without an exception, or the exception is not a part of error class framework, it will be None.

See Also:
  • Constructor Details

    • QueryTerminatedEvent

      public QueryTerminatedEvent(UUID id, UUID runId, scala.Option<String> exception)
  • Method Details

    • errorClassOnException

      public scala.Option<String> errorClassOnException()
    • exception

      public scala.Option<String> exception()
    • id

      public UUID id()
    • json

      public String json()
    • runId

      public UUID runId()