@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.
|
int |
localBlocksFetched
Number of local blocks fetched in shuffles by tasks.
|
int |
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(int remoteBlocksFetched,
int localBlocksFetched,
long fetchWaitTime,
long remoteBytesRead) |
ShuffleReadMetrics(org.apache.spark.executor.TaskMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
int |
getTotalBlocksFetched()
Number of blocks fetched in shuffle by tasks (remote or local).
|
public final int remoteBlocksFetched
public final int localBlocksFetched
public final long fetchWaitTime
public final long remoteBytesRead
Copyright © 2016 The Apache Software Foundation. All rights reserved.