Package org.apache.spark.status.api.v1
Class ShuffleReadMetrics
Object
org.apache.spark.status.api.v1.ShuffleReadMetrics
-
Method Summary
Modifier and TypeMethodDescriptionlong
long
long
long
long
long
long
long
-
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
-