Packages

class SinkProgress extends Serializable

Information about progress made for a sink in the execution of a StreamingQuery during a trigger. See StreamingQueryProgress for more information.

Annotations
@Evolving()
Source
progress.scala
Since

2.1.0

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SinkProgress
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. val description: String
  2. def json: String

    The compact JSON representation of this progress.

  3. val metrics: Map[String, String]
  4. val numOutputRows: Long
  5. def prettyJson: String

    The pretty (i.e.

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

  6. def toString(): String
    Definition Classes
    SinkProgress → AnyRef → Any