public class SinkProgress
extends Object
implements scala.Serializable
StreamingQuery
during a trigger. See StreamingQueryProgress
for more information.
param: description Description of the source corresponding to this status. param: numOutputRows Number of rows written to the sink or -1 for Continuous Mode (temporarily) or Sink V1 (until decommissioned).
Modifier and Type | Method and Description |
---|---|
static SinkProgress |
apply(String description,
scala.Option<Object> numOutputRows,
java.util.Map<String,String> metrics) |
static long |
DEFAULT_NUM_OUTPUT_ROWS() |
String |
description() |
String |
json()
The compact JSON representation of this progress.
|
java.util.Map<String,String> |
metrics() |
long |
numOutputRows() |
String |
prettyJson()
The pretty (i.e.
|
String |
toString() |
public static long DEFAULT_NUM_OUTPUT_ROWS()
public static SinkProgress apply(String description, scala.Option<Object> numOutputRows, java.util.Map<String,String> metrics)
public String description()
public long numOutputRows()
public java.util.Map<String,String> metrics()
public String json()
public String prettyJson()
public String toString()
toString
in class Object