org.apache.spark.sql.streaming

Class StreamingQueryInfo

Object

org.apache.spark.sql.streaming.StreamingQueryInfo

public class StreamingQueryInfo
extends Object

:: Experimental :: A class used to report information about the progress of a StreamingQuery.

param: name The StreamingQuery name. This name is unique across all active queries. param: id The StreamingQuery id. This id is unique across all queries that have been started in the current process. param: sourceStatuses The current statuses of the StreamingQuery's sources. param: sinkStatus The current status of the StreamingQuery's sink.

Method Summary

Methods

Modifier and Type	Method and Description
long	id()
String	name()
SinkStatus	sinkStatus()
scala.collection.Seq<SourceStatus>	sourceStatuses()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

name

public String name()

id

public long id()

sourceStatuses

public scala.collection.Seq<SourceStatus> sourceStatuses()

sinkStatus

public SinkStatus sinkStatus()