ShuffleReadMetrics

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[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

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

   

   Definition Classes

   AnyRef

7. def equals(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

8. def fetchWaitTime: Long

   

   Time the task spent waiting for remote shuffle blocks.

   Time the task spent waiting for remote shuffle blocks. This only includes the time blocking on shuffle input data. For instance if block B is being fetched while the task is still not finished processing block A, it is not considered to be blocking on block B.

9. def finalize(): Unit

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

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

    

    Definition Classes

    AnyRef → Any

11. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

12. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

13. def localBlocksFetched: Long

    

    Number of local blocks fetched in this shuffle by this task.

14. def localBytesRead: Long

    

    Shuffle data that was read from the local disk (as opposed to from a remote executor).

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

    

    Definition Classes

    AnyRef

16. final def notify(): Unit

    

    Definition Classes

    AnyRef

17. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

18. def read(kryo: Kryo, input: Input, context: TaskContext): Unit

    

19. final def read(kryo: Kryo, input: Input): Unit

    

    Definition Classes

    ShuffleReadMetrics → KryoSerializable

20. def recordsRead: Long

    

    Total number of records read from the shuffle by this task.

21. def remoteBlocksFetched: Long

    

    Number of remote blocks fetched in this shuffle by this task.

22. def remoteBytesRead: Long

    

    Total number of remote bytes read from the shuffle by this task.

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

    

    Definition Classes

    AnyRef

24. def toString(): String

    

    Definition Classes

    AnyRef → Any

25. def totalBlocksFetched: Long

    

    Number of blocks fetched in this shuffle by this task (remote or local).

26. def totalBytesRead: Long

    

    Total bytes fetched in the shuffle by this task (both remote and local).

27. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

30. def write(kryo: Kryo, output: Output): Unit

    

    Definition Classes

    ShuffleReadMetrics → KryoSerializable