com.iresium.airavat

TaskMetricTuple

Related Doc: package airavat

case class TaskMetricTuple(id: String, taskId: Long, stageId: Long, jobId: Int, executorId: Option[String], attemptNumber: Option[Int], duration: Option[Long], gettingResultTime: Option[Long], diskBytesSpilled: Option[Long], executorCpuTime: Option[Long], executorDeserializeCpuTime: Option[Long], executorDeserializeTime: Option[Long], executorRunTime: Option[Long], inputBytesRead: Option[Long], inputRecordsRead: Option[Long], jvmGCTime: Option[Long], memoryBytesSpilled: Option[Long], outputBytesWritten: Option[Long], outputRecordsWritten: Option[Long], peakExecutionMemory: Option[Long], resultSerializationTime: Option[Long], resultSize: Option[Long], shuffleReadFetchWaitTime: Option[Long], shuffleReadLocalBlocksFetched: Option[Long], shuffleReadLocalBytesRead: Option[Long], shuffleReadOutputRecordsRead: Option[Long], shuffleReadRemoteBlocksFetched: Option[Long], shuffleReadRemoteBytesRead: Option[Long], shuffleReadRemoteBytesReadToDisk: Option[Long], shuffleWriteBytesWritten: Option[Long], shuffleWriteRecordsWritten: Option[Long], shuffleWriteWriteTime: Option[Long], timestamp: String = ...) extends Product with Serializable

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. TaskMetricTuple
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TaskMetricTuple(id: String, taskId: Long, stageId: Long, jobId: Int, executorId: Option[String], attemptNumber: Option[Int], duration: Option[Long], gettingResultTime: Option[Long], diskBytesSpilled: Option[Long], executorCpuTime: Option[Long], executorDeserializeCpuTime: Option[Long], executorDeserializeTime: Option[Long], executorRunTime: Option[Long], inputBytesRead: Option[Long], inputRecordsRead: Option[Long], jvmGCTime: Option[Long], memoryBytesSpilled: Option[Long], outputBytesWritten: Option[Long], outputRecordsWritten: Option[Long], peakExecutionMemory: Option[Long], resultSerializationTime: Option[Long], resultSize: Option[Long], shuffleReadFetchWaitTime: Option[Long], shuffleReadLocalBlocksFetched: Option[Long], shuffleReadLocalBytesRead: Option[Long], shuffleReadOutputRecordsRead: Option[Long], shuffleReadRemoteBlocksFetched: Option[Long], shuffleReadRemoteBytesRead: Option[Long], shuffleReadRemoteBytesReadToDisk: Option[Long], shuffleWriteBytesWritten: Option[Long], shuffleWriteRecordsWritten: Option[Long], shuffleWriteWriteTime: Option[Long], timestamp: String = ...)

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. val attemptNumber: Option[Int]

  6. def clone(): AnyRef

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

  7. val diskBytesSpilled: Option[Long]

  8. val duration: Option[Long]

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

    Definition Classes
    AnyRef

  10. val executorCpuTime: Option[Long]

  11. val executorDeserializeCpuTime: Option[Long]

  12. val executorDeserializeTime: Option[Long]

  13. val executorId: Option[String]

  14. val executorRunTime: Option[Long]

  15. def finalize(): Unit

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

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

    Definition Classes
    AnyRef → Any

  17. val gettingResultTime: Option[Long]

  18. val id: String

  19. val inputBytesRead: Option[Long]

  20. val inputRecordsRead: Option[Long]

  21. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  22. val jobId: Int

  23. val jvmGCTime: Option[Long]

  24. val memoryBytesSpilled: Option[Long]

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

    Definition Classes
    AnyRef

  26. final def notify(): Unit

    Definition Classes
    AnyRef

  27. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  28. val outputBytesWritten: Option[Long]

  29. val outputRecordsWritten: Option[Long]

  30. val peakExecutionMemory: Option[Long]

  31. val resultSerializationTime: Option[Long]

  32. val resultSize: Option[Long]

  33. val shuffleReadFetchWaitTime: Option[Long]

  34. val shuffleReadLocalBlocksFetched: Option[Long]

  35. val shuffleReadLocalBytesRead: Option[Long]

  36. val shuffleReadOutputRecordsRead: Option[Long]

  37. val shuffleReadRemoteBlocksFetched: Option[Long]

  38. val shuffleReadRemoteBytesRead: Option[Long]

  39. val shuffleReadRemoteBytesReadToDisk: Option[Long]

  40. val shuffleWriteBytesWritten: Option[Long]

  41. val shuffleWriteRecordsWritten: Option[Long]

  42. val shuffleWriteWriteTime: Option[Long]

  43. val stageId: Long

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

    Definition Classes
    AnyRef

  45. val taskId: Long

  46. val timestamp: String

  47. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped