org.apache.spark.sql.streaming

Class StateOperatorProgress

Object

org.apache.spark.sql.streaming.StateOperatorProgress

All Implemented Interfaces:

java.io.Serializable

public class StateOperatorProgress
extends Object
implements scala.Serializable

:: Experimental :: Information about updates made to stateful operators in a StreamingQuery during a trigger.

See Also:

Serialized Form

Method Summary

Methods

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

Methods inherited from class Object

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

Method Detail

numRowsTotal

public long numRowsTotal()

numRowsUpdated

public long numRowsUpdated()

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.