Package org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryStartedEvent

Object

org.apache.spark.sql.streaming.StreamingQueryListener.QueryStartedEvent

All Implemented Interfaces:

Serializable, SparkListenerEvent, StreamingQueryListener.Event, scala.Serializable

Enclosing class:

StreamingQueryListener

public static class StreamingQueryListener.QueryStartedEvent
extends Object
implements StreamingQueryListener.Event, scala.Serializable

Event representing the start 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: name User-specified name of the query, null if not specified. param: timestamp The timestamp to start a query.

Since:

2.1.0

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
UUID	id()
String	json()
String	name()
UUID	runId()
String	timestamp()

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

Method Details

id

public UUID id()

json

public String json()

name

public String name()

runId

public UUID runId()

timestamp

public String timestamp()