Package org.apache.spark.sql.streaming

Class SinkProgress

Object

org.apache.spark.sql.streaming.SinkProgress

All Implemented Interfaces:

Serializable

public class SinkProgress
extends Object
implements 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:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
static SinkProgress	apply(String description, scala.Option<Object> numOutputRows, Map<String,String> metrics)
static long	DEFAULT_NUM_OUTPUT_ROWS()
String	description()
String	json()	The compact JSON representation of this progress.
Map<String,String>	metrics()
long	numOutputRows()
String	prettyJson()	The pretty (i.e.
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

DEFAULT_NUM_OUTPUT_ROWS

public static long DEFAULT_NUM_OUTPUT_ROWS()

apply

public static SinkProgress apply(String description,
 scala.Option<Object> numOutputRows,
 Map<String,String> metrics)

description

public String description()

numOutputRows

public long numOutputRows()

metrics

public Map<String,String> metrics()

json

public String json()

The compact JSON representation of this progress.

prettyJson

public String prettyJson()

The pretty (i.e. indented) JSON representation of this progress.

toString

public String toString()

Overrides:

toString in class Object