org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryStartedEvent

Object

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

All Implemented Interfaces:

SparkListenerEvent, StreamingQueryListener.Event

Enclosing class:

StreamingQueryListener

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

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

Method Summary

Modifier and Type	Method and Description
java.util.UUID	id()
String	name()
java.util.UUID	runId()
String	timestamp()

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()

name

public String name()

runId

public java.util.UUID runId()

timestamp

public String timestamp()