Package org.apache.spark.sql.streaming

Class StreamingQueryListener.QueryProgressEvent

Object

org.apache.spark.sql.streaming.StreamingQueryListener.QueryProgressEvent

All Implemented Interfaces:

Serializable, SparkListenerEvent, StreamingQueryListener.Event, scala.Serializable

Enclosing class:

StreamingQueryListener

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

Event representing any progress updates in a query. param: progress The query progress updates.

Since:

2.1.0

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
String	json()
StreamingQueryProgress	progress()

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

json

public String json()

progress

public StreamingQueryProgress progress()