Package org.apache.spark.sql.streaming
Class SinkProgress
Object
org.apache.spark.sql.streaming.SinkProgress
- All Implemented Interfaces:
Serializable
Information about progress made for a sink in the execution of a
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).
- Since:
- 2.1.0
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionstatic SinkProgress
static long
json()
The compact JSON representation of this progress.metrics()
long
The pretty (i.e.toString()
-
Method Details
-
DEFAULT_NUM_OUTPUT_ROWS
public static long DEFAULT_NUM_OUTPUT_ROWS() -
apply
-
description
-
numOutputRows
public long numOutputRows() -
metrics
-
json
The compact JSON representation of this progress. -
prettyJson
The pretty (i.e. indented) JSON representation of this progress. -
toString
-