Package org.apache.spark.status.api.v1

Class ShuffleReadMetrics

Object
org.apache.spark.status.api.v1.ShuffleReadMetrics
public class ShuffleReadMetrics extends Object

  • Method Details

    • fetchWaitTime

      public long fetchWaitTime()

    • localBlocksFetched

      public long localBlocksFetched()

    • localBytesRead

      public long localBytesRead()

    • recordsRead

      public long recordsRead()

    • remoteBlocksFetched

      public long remoteBlocksFetched()

    • remoteBytesRead

      public long remoteBytesRead()

    • remoteBytesReadToDisk

      public long remoteBytesReadToDisk()

    • remoteReqsDuration

      public long remoteReqsDuration()

    • shufflePushReadMetrics

      public ShufflePushReadMetrics shufflePushReadMetrics()