org.apache.hadoop.mapred

类 TaskTrackerMetricsSource

java.lang.Object

org.apache.hadoop.mapred.TaskTrackerMetricsSource

所有已实现的接口:

MetricsSource

public class TaskTrackerMetricsSource
extends Object
implements MetricsSource

Instrumentation for metrics v2

字段概要

字段

限定符和类型	字段和说明
protected TaskTracker	tt

构造器概要

构造器

构造器和说明
TaskTrackerMetricsSource(TaskTracker tt)

方法概要

方法

限定符和类型	方法和说明
void	completeTask(TaskAttemptID t) invoked when task attempt t succeeds
void	getMetrics(MetricsBuilder builder, boolean all) Get metrics from the source
void	reportTaskEnd(TaskAttemptID t) called when task t has just finished.
void	reportTaskLaunch(TaskAttemptID t, File stdout, File stderr) Called just before task attempt t starts.
void	taskFailedPing(TaskAttemptID t)
void	timedoutTask(TaskAttemptID t)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

tt

protected final TaskTracker tt

构造器详细资料

TaskTrackerMetricsSource

public TaskTrackerMetricsSource(TaskTracker tt)

方法详细资料

getMetrics

public void getMetrics(MetricsBuilder builder,
              boolean all)

从接口复制的说明: MetricsSource

Get metrics from the source

指定者:

getMetrics 在接口中 MetricsSource

参数:

builder - to contain the resulting metrics snapshot

all - if true, return all metrics even if unchanged.

completeTask

public void completeTask(TaskAttemptID t)

invoked when task attempt t succeeds

timedoutTask

public void timedoutTask(TaskAttemptID t)

taskFailedPing

public void taskFailedPing(TaskAttemptID t)

reportTaskLaunch

public void reportTaskLaunch(TaskAttemptID t,
                    File stdout,
                    File stderr)

Called just before task attempt t starts.

参数:

stdout - the file containing standard out of the new task

stderr - the file containing standard error of the new task

reportTaskEnd

public void reportTaskEnd(TaskAttemptID t)

called when task t has just finished.

参数:

t -