StreamingQueryStatus

org.apache.spark.sql.streaming.StreamingQueryStatus
case class StreamingQueryStatus(message: String, isDataAvailable: Boolean, isTriggerActive: Boolean, isActive: Boolean)

A snapshot of a StreamingQuery's current status.

Value parameters

isActive

whether the query is still running.

isDataAvailable

whether there is any data available to be processed.

isTriggerActive

whether a trigger is currently active (a micro-batch is being processed).

message

a human-readable description of what the query is currently doing.

Attributes

Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Inherited methods

def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product