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