org.apache.spark.sql.streaming

Class SinkStatus

Object

org.apache.spark.sql.streaming.SinkStatus

public class SinkStatus
extends Object

:: Experimental :: Status and metrics of a streaming sink.

param: description Description of the source corresponding to this status. param: offsetDesc Description of the current offsets up to which data has been written by the sink.

Since:

2.0.0

Method Summary

Methods

Modifier and Type	Method and Description
static SinkStatus	apply(String desc, String offsetDesc)
String	description()
String	json() The compact JSON representation of this status.
String	offsetDesc()
String	prettyJson() The pretty (i.e.
String	toString()

Methods inherited from class Object

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

Method Detail

apply

public static SinkStatus apply(String desc,
               String offsetDesc)

description

public String description()

offsetDesc

public String offsetDesc()

json

public String json()

The compact JSON representation of this status.

prettyJson

public String prettyJson()

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

toString

public String toString()

Overrides:

toString in class Object