public class StreamingQueryInfo
extends Object
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.
Modifier and Type | Method and Description |
---|---|
long |
id() |
String |
name() |
SinkStatus |
sinkStatus() |
scala.collection.Seq<SourceStatus> |
sourceStatuses() |
public String name()
public long id()
public scala.collection.Seq<SourceStatus> sourceStatuses()
public SinkStatus sinkStatus()