Package org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryIdleEvent

Object

org.apache.spark.sql.streaming.StreamingQueryListener.QueryIdleEvent

All Implemented Interfaces:

Serializable, SparkListenerEvent, StreamingQueryListener.Event, scala.Serializable

Enclosing class:

StreamingQueryListener

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

Event representing that query is idle and waiting for new data to process.

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: timestamp The timestamp when the latest no-batch trigger happened.

Since:

3.5.0

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
UUID	id()
String	json()
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()

runId

public UUID runId()

timestamp

public String timestamp()