Class

org.apache.spark.sql.streaming

SourceProgress

Related Doc: package streaming

Permalink

class SourceProgress extends AnyRef

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

Annotations
@Experimental()
Source
progress.scala
Since

2.1.0

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SourceProgress
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SourceProgress(description: String, startOffset: String, endOffset: String, numInputRows: Long, inputRowsPerSecond: Double, processedRowsPerSecond: Double)

    Permalink

    description

    Description of the source.

    startOffset

    The starting offset for data being read.

    endOffset

    The ending offset for data being read.

    numInputRows

    The number of records read from this source.

    inputRowsPerSecond

    The rate at which data is arriving from this source.

    processedRowsPerSecond

    The rate at which data from this source is being procressed by Spark.

    Attributes
    protected[org.apache.spark.sql]

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. val description: String

    Permalink

    Description of the source.

  7. val endOffset: String

    Permalink

    The ending offset for data being read.

  8. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  9. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  10. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  11. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  12. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  13. val inputRowsPerSecond: Double

    Permalink

    The rate at which data is arriving from this source.

  14. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  15. def json: String

    Permalink

    The compact JSON representation of this progress.

  16. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  17. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  18. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  19. val numInputRows: Long

    Permalink

    The number of records read from this source.

  20. def prettyJson: String

    Permalink

    The pretty (i.e.

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

  21. val processedRowsPerSecond: Double

    Permalink

    The rate at which data from this source is being procressed by Spark.

  22. val startOffset: String

    Permalink

    The starting offset for data being read.

  23. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  24. def toString(): String

    Permalink
    Definition Classes
    SourceProgress → AnyRef → Any

  25. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  27. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped