Packages

class SQLShuffleReadMetricsReporter extends TempShuffleReadMetrics

A shuffle metrics reporter for SQL exchange operators.

Linear Supertypes
TempShuffleReadMetrics, ShuffleReadMetricsReporter, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SQLShuffleReadMetricsReporter
  2. TempShuffleReadMetrics
  3. ShuffleReadMetricsReporter
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SQLShuffleReadMetricsReporter(tempMetrics: TempShuffleReadMetrics, metrics: Map[String, SQLMetric])

    tempMetrics

    TempShuffleReadMetrics created in TaskContext.

    metrics

    All metrics in current SparkPlan. This param should not empty and contains all shuffle metrics defined in createShuffleReadMetrics.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. def corruptMergedBlockChunks: Long
    Definition Classes
    TempShuffleReadMetrics
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. def fetchWaitTime: Long
    Definition Classes
    TempShuffleReadMetrics
  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def incCorruptMergedBlockChunks(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  13. def incFetchWaitTime(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  14. def incLocalBlocksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  15. def incLocalBytesRead(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  16. def incLocalMergedBlocksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  17. def incLocalMergedBytesRead(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  18. def incLocalMergedChunksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  19. def incMergedFetchFallbackCount(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  20. def incRecordsRead(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  21. def incRemoteBlocksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  22. def incRemoteBytesRead(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  23. def incRemoteBytesReadToDisk(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  24. def incRemoteMergedBlocksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  25. def incRemoteMergedBytesRead(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  26. def incRemoteMergedChunksFetched(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  27. def incRemoteMergedReqsDuration(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  28. def incRemoteReqsDuration(v: Long): Unit
    Definition Classes
    SQLShuffleReadMetricsReporter → TempShuffleReadMetrics → ShuffleReadMetricsReporter
  29. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  30. def localBlocksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  31. def localBytesRead: Long
    Definition Classes
    TempShuffleReadMetrics
  32. def localMergedBlocksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  33. def localMergedBytesRead: Long
    Definition Classes
    TempShuffleReadMetrics
  34. def localMergedChunksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  35. def mergedFetchFallbackCount: Long
    Definition Classes
    TempShuffleReadMetrics
  36. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  37. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  38. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  39. def recordsRead: Long
    Definition Classes
    TempShuffleReadMetrics
  40. def remoteBlocksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  41. def remoteBytesRead: Long
    Definition Classes
    TempShuffleReadMetrics
  42. def remoteBytesReadToDisk: Long
    Definition Classes
    TempShuffleReadMetrics
  43. def remoteMergedBlocksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  44. def remoteMergedBytesRead: Long
    Definition Classes
    TempShuffleReadMetrics
  45. def remoteMergedChunksFetched: Long
    Definition Classes
    TempShuffleReadMetrics
  46. def remoteMergedReqsDuration: Long
    Definition Classes
    TempShuffleReadMetrics
  47. def remoteReqsDuration: Long
    Definition Classes
    TempShuffleReadMetrics
  48. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  49. def toString(): String
    Definition Classes
    AnyRef → Any
  50. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  51. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  52. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from TempShuffleReadMetrics

Inherited from ShuffleReadMetricsReporter

Inherited from AnyRef

Inherited from Any

Ungrouped