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 A 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

exception

public scala.Option<String> exception()

id

public java.util.UUID id()

runId

public java.util.UUID runId()