org.apache.spark.sql.streaming

Class SinkProgress

Object

org.apache.spark.sql.streaming.SinkProgress

All Implemented Interfaces:

java.io.Serializable

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

Since:

2.1.0

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
String	description()
String	json() The compact JSON representation of this progress.
String	prettyJson() The pretty (i.e.
String	toString()

Methods inherited from class Object

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

Method Detail

description

public String description()

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