org.apache.spark.status.api.v1

Class ShuffleReadMetrics

Object

org.apache.spark.status.api.v1.ShuffleReadMetrics

public class ShuffleReadMetrics
extends Object

Method Summary

Modifier and Type	Method and Description
long	fetchWaitTime()
long	localBlocksFetched()
long	localBytesRead()
long	recordsRead()
long	remoteBlocksFetched()
long	remoteBytesRead()
long	remoteBytesReadToDisk()
long	remoteReqsDuration()
ShufflePushReadMetrics	shufflePushReadMetrics()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

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()