Package | Description |
---|---|
org.apache.hadoop.mapred |
A software framework for easily writing applications which process vast
amounts of data (multi-terabyte data-sets) parallelly on large clusters
(thousands of nodes) built of commodity hardware in a reliable, fault-tolerant
manner.
|
Modifier and Type | Method and Description |
---|---|
static Counters |
Counters.fromEscapedCompactString(java.lang.String compactString)
Deprecated.
Convert a stringified (by
makeEscapedCompactString() counter
representation into a counter object. |
Counters |
TaskStatus.getCounters()
Get task's counters.
|
Counters |
JobInProgress.getCounters()
Returns the total job counters, by adding together the job,
the map and the reduce counters.
|
Counters |
TaskInProgress.getCounters()
Get the task's counters
|
Counters |
TaskReport.getCounters()
A table of counters.
|
Counters |
RunningJob.getCounters()
Gets the counters for this job.
|
Counters |
JobInProgress.getJobCounters()
Returns the job-level counters.
|
Counters |
JobTracker.getJobCounters(JobID jobid) |
Counters |
LocalJobRunner.getJobCounters(JobID id) |
Counters |
JobInProgress.getMapCounters()
Returns map phase counters by summing over all map tasks in progress.
|
Counters |
JobInProgress.getReduceCounters()
Returns map phase counters by summing over all map tasks in progress.
|
static Counters |
Counters.sum(Counters a,
Counters b)
Deprecated.
Convenience method for computing the sum of two sets of counters.
|
Modifier and Type | Method and Description |
---|---|
void |
Counters.incrAllCounters(Counters other)
Deprecated.
Increments multiple counters by their amounts in another Counters
instance.
|
static void |
JobHistory.JobInfo.logFinished(JobID jobId,
long finishTime,
int finishedMaps,
int finishedReduces,
int failedMaps,
int failedReduces,
Counters mapCounters,
Counters reduceCounters,
Counters counters)
Log job finished.
|
static void |
JobHistory.ReduceAttempt.logFinished(TaskAttemptID taskAttemptId,
long shuffleFinished,
long sortFinished,
long finishTime,
java.lang.String hostName,
java.lang.String taskType,
java.lang.String stateString,
Counters counter)
Log finished event of this task.
|
static void |
JobHistory.MapAttempt.logFinished(TaskAttemptID taskAttemptId,
long finishTime,
java.lang.String hostName,
java.lang.String taskType,
java.lang.String stateString,
Counters counter)
Log finish time of map task attempt.
|
static void |
JobHistory.Task.logFinished(TaskID taskId,
java.lang.String taskType,
long finishTime,
Counters counters)
Log finish time of task.
|
void |
TaskStatus.setCounters(Counters counters)
Set the task's counters.
|
static Counters |
Counters.sum(Counters a,
Counters b)
Deprecated.
Convenience method for computing the sum of two sets of counters.
|
Constructor and Description |
---|
TaskStatus(TaskAttemptID taskid,
float progress,
int numSlots,
TaskStatus.State runState,
java.lang.String diagnosticInfo,
java.lang.String stateString,
java.lang.String taskTracker,
TaskStatus.Phase phase,
Counters counters) |
Copyright © 2009 The Apache Software Foundation