Packages

class StageData extends AnyRef

Source
api.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StageData
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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. val accumulatorUpdates: Seq[AccumulableInfo]
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val attemptId: Int
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  8. val completionTime: Option[Date]
  9. val description: Option[String]
  10. val details: String
  11. val diskBytesSpilled: Long
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  14. val executorCpuTime: Long
  15. val executorDeserializeCpuTime: Long
  16. val executorDeserializeTime: Long
  17. val executorMetricsDistributions: Option[ExecutorMetricsDistributions]
  18. val executorRunTime: Long
  19. val executorSummary: Option[Map[String, ExecutorStageSummary]]
  20. val failureReason: Option[String]
  21. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  22. val firstTaskLaunchedTime: Option[Date]
  23. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  24. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  25. val inputBytes: Long
  26. val inputRecords: Long
  27. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  28. val isShufflePushEnabled: Boolean
  29. val jvmGcTime: Long
  30. val killedTasksSummary: Map[String, Int]
  31. val memoryBytesSpilled: Long
  32. val name: String
  33. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  34. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  35. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  36. val numActiveTasks: Int
  37. val numCompleteTasks: Int
  38. val numCompletedIndices: Int
  39. val numFailedTasks: Int
  40. val numKilledTasks: Int
  41. val numTasks: Int
  42. val outputBytes: Long
  43. val outputRecords: Long
  44. val peakExecutionMemory: Long
  45. val peakExecutorMetrics: Option[ExecutorMetrics]
  46. val rddIds: Seq[Int]
  47. val resourceProfileId: Int
  48. val resultSerializationTime: Long
  49. val resultSize: Long
  50. val schedulingPool: String
  51. val shuffleCorruptMergedBlockChunks: Long
  52. val shuffleFetchWaitTime: Long
  53. val shuffleLocalBlocksFetched: Long
  54. val shuffleLocalBytesRead: Long
  55. val shuffleMergedFetchFallbackCount: Long
  56. val shuffleMergedLocalBlocksFetched: Long
  57. val shuffleMergedLocalBytesRead: Long
  58. val shuffleMergedLocalChunksFetched: Long
  59. val shuffleMergedRemoteBlocksFetched: Long
  60. val shuffleMergedRemoteBytesRead: Long
  61. val shuffleMergedRemoteChunksFetched: Long
  62. val shuffleMergedRemoteReqsDuration: Long
  63. val shuffleMergersCount: Int
  64. val shuffleReadBytes: Long
  65. val shuffleReadRecords: Long
  66. val shuffleRemoteBlocksFetched: Long
  67. val shuffleRemoteBytesRead: Long
  68. val shuffleRemoteBytesReadToDisk: Long
  69. val shuffleRemoteReqsDuration: Long
  70. val shuffleWriteBytes: Long
  71. val shuffleWriteRecords: Long
  72. val shuffleWriteTime: Long
  73. val speculationSummary: Option[SpeculationStageSummary]
  74. val stageId: Int
  75. val status: StageStatus
  76. val submissionTime: Option[Date]
  77. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  78. val taskMetricsDistributions: Option[TaskMetricDistributions]
  79. val tasks: Option[Map[Long, TaskData]]
  80. def toString(): String
    Definition Classes
    AnyRef → Any
  81. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  82. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  83. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped