public class SourceStatus
extends Object
param: description Description of the source corresponding to this status. param: offsetDesc Description of the current offset if known. param: inputRate Current rate (rows/sec) at which data is being generated by the source. param: processingRate Current rate (rows/sec) at which the query is processing data from the source. param: triggerDetails Low-level details of the currently active trigger (e.g. number of rows processed in trigger, latency of intermediate steps, etc.). If no trigger is active, then it will have details of the last completed trigger.
Modifier and Type | Method and Description |
---|---|
static SourceStatus |
apply(String desc,
String offsetDesc,
double inputRate,
double processingRate,
scala.collection.immutable.Map<String,String> triggerDetails) |
String |
description() |
double |
inputRate() |
String |
json()
The compact JSON representation of this status.
|
String |
offsetDesc() |
String |
prettyJson()
The pretty (i.e.
|
double |
processingRate() |
String |
toString() |
java.util.Map<String,String> |
triggerDetails() |
public static SourceStatus apply(String desc, String offsetDesc, double inputRate, double processingRate, scala.collection.immutable.Map<String,String> triggerDetails)
public String description()
public String offsetDesc()
public double inputRate()
public double processingRate()
public java.util.Map<String,String> triggerDetails()
public String json()
public String prettyJson()
public String toString()
toString
in class Object