@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) |
public final int remoteBlocksFetched
public final int localBlocksFetched
public final long fetchWaitTime
public final long remoteBytesRead
Copyright © 2017 The Apache Software Foundation. All rights reserved.