public class ReduceTaskAttemptInfo extends TaskAttemptInfo
ReduceTaskAttemptInfo
represents the information with regard to a
reduce task attempt.allSplits, state, taskInfo
Constructor and Description |
---|
ReduceTaskAttemptInfo(TaskStatus.State state,
TaskInfo taskInfo,
long shuffleTime,
long mergeTime,
long reduceTime)
Deprecated.
please use the constructor with
(state, taskInfo, shuffleTime, mergeTime, reduceTime
List<List<Integer>> allSplits)
instead.
see LoggedTaskAttempt for an explanation of
allSplits .
If there are no known splits, use null . |
ReduceTaskAttemptInfo(TaskStatus.State state,
TaskInfo taskInfo,
long shuffleTime,
long mergeTime,
long reduceTime,
List<List<Integer>> allSplits) |
Modifier and Type | Method and Description |
---|---|
long |
getMergeRuntime()
Get the runtime for the merge phase of the reduce task-attempt
|
long |
getReduceRuntime()
Get the runtime for the reduce phase of the reduce task-attempt.
|
long |
getRuntime()
Get the total runtime for the task-attempt.
|
long |
getShuffleRuntime()
Get the runtime for the shuffle phase of the reduce task-attempt.
|
getRunState, getSplitVector, getTaskInfo
public ReduceTaskAttemptInfo(TaskStatus.State state, TaskInfo taskInfo, long shuffleTime, long mergeTime, long reduceTime, List<List<Integer>> allSplits)
@Deprecated public ReduceTaskAttemptInfo(TaskStatus.State state, TaskInfo taskInfo, long shuffleTime, long mergeTime, long reduceTime)
(state, taskInfo, shuffleTime, mergeTime, reduceTime
List<List<Integer>> allSplits)
instead.
see LoggedTaskAttempt
for an explanation of
allSplits
.
If there are no known splits, use null
.public long getReduceRuntime()
public long getShuffleRuntime()
public long getMergeRuntime()
public long getRuntime()
TaskAttemptInfo
getRuntime
in class TaskAttemptInfo
Copyright © 2013 Apache Software Foundation. All rights reserved.