@InterfaceAudience.Private public class ShuffleReadMetrics extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
long |
fetchWaitTime
Time tasks spent waiting for remote shuffle blocks.
|
long |
localBlocksFetched
Number of local blocks fetched in shuffles by tasks.
|
long |
remoteBlocksFetched
Number of remote blocks fetched in shuffles by tasks.
|
long |
remoteBytesRead
Total number of remote bytes read from the shuffle by tasks.
|
Constructor and Description |
---|
ShuffleReadMetrics(long remoteBlocksFetched,
long localBlocksFetched,
long fetchWaitTime,
long remoteBytesRead) |
ShuffleReadMetrics(org.apache.spark.executor.TaskMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
long |
getTotalBlocksFetched()
Number of blocks fetched in shuffle by tasks (remote or local).
|
public final long remoteBlocksFetched
public final long localBlocksFetched
public final long fetchWaitTime
public final long remoteBytesRead
Copyright © 2022 The Apache Software Foundation. All rights reserved.