类 org.apache.hadoop.mapred.Counters
的使用

使用Counters的程序包

程序包	说明
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.
org.apache.hadoop.mapreduce

org.apache.hadoop.mapred中Counters的使用

返回Counters的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
static Counters	Counters.fromEscapedCompactString(String compactString) Convert a stringified counter representation into a counter object.
Counters	TaskStatus.getCounters() Get 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	LocalJobRunner.getJobCounters(JobID id)
Counters	JobTracker.getJobCounters(JobID jobid)
static Counters	Counters.sum(Counters a, Counters b) Convenience method for computing the sum of two sets of counters.

参数类型为Counters的org.apache.hadoop.mapred中的方法

限定符和类型	方法和说明
boolean	JobInProgress.getCounters(Counters result) Returns the total job counters, by adding together the job, the map and the reduce counters.
boolean	JobInProgress.getMapCounters(Counters counters) Returns map phase counters by summing over all map tasks in progress.
boolean	JobInProgress.getReduceCounters(Counters counters) Returns map phase counters by summing over all map tasks in progress.
void	Counters.incrAllCounters(Counters other) 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. closes the job file in history.
static void	JobHistory.ReduceAttempt.logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName, String taskType, String stateString, Counters counter) Log finished event of this task.
static void	JobHistory.MapAttempt.logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName, String taskType, String stateString, Counters counter) Log finish time of map task attempt.
static void	JobHistory.Task.logFinished(TaskID taskId, 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) Convenience method for computing the sum of two sets of counters.

参数类型为Counters的org.apache.hadoop.mapred中的构造器

构造器和说明
TaskStatus(TaskAttemptID taskid, float progress, int numSlots, TaskStatus.State runState, String diagnosticInfo, String stateString, String taskTracker, TaskStatus.Phase phase, Counters counters)

org.apache.hadoop.mapreduce中Counters的使用

参数类型为Counters的org.apache.hadoop.mapreduce中的构造器

构造器和说明
Counters(Counters counters)