Package org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryTerminatedEvent

Object

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

All Implemented Interfaces:

Serializable, SparkListenerEvent, StreamingQueryListener.Event

Enclosing class:

StreamingQueryListener

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

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

Since:

2.1.0

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
QueryTerminatedEvent(UUID id, UUID runId, scala.Option<String> exception)

Method Summary

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

Methods inherited from class java.lang.Object

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

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

logEvent

Constructor Details

QueryTerminatedEvent

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

Method Details

id

public UUID id()

runId

public UUID runId()

exception

public scala.Option<String> exception()

errorClassOnException

public scala.Option<String> errorClassOnException()

json

public String json()