org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryTerminatedEvent

Object

org.apache.spark.sql.streaming.StreamingQueryListener.QueryTerminatedEvent

All Implemented Interfaces:

SparkListenerEvent, StreamingQueryListener.Event

Enclosing class:

StreamingQueryListener

public static class StreamingQueryListener.QueryTerminatedEvent
extends Object
implements StreamingQueryListener.Event

Event representing that termination of a query.

param: id An unique query id that persists across restarts. See StreamingQuery.id(). 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.

Since:

2.1.0

Method Summary

Modifier and Type	Method and Description
scala.Option<String>	exception()
java.util.UUID	id()
java.util.UUID	runId()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.scheduler.SparkListenerEvent

logEvent

Method Detail

id

public java.util.UUID id()

runId

public java.util.UUID runId()

exception

public scala.Option<String> exception()