org.apache.hadoop.mapred

类 Task.TaskReporter

java.lang.Object

org.apache.hadoop.mapreduce.StatusReporter

org.apache.hadoop.mapred.Task.TaskReporter

所有已实现的接口:

Runnable, Reporter, Progressable

封闭类:

Task

protected class Task.TaskReporter
extends StatusReporter
implements Runnable, Reporter

字段概要

从接口继承的字段 org.apache.hadoop.mapred.Reporter

NULL

方法概要

方法

限定符和类型	方法和说明
Counters.Counter	getCounter(Enum<?> name) Get the Counters.Counter of the given group with the given name.
Counters.Counter	getCounter(String group, String name) Get the Counters.Counter of the given group with the given name.
InputSplit	getInputSplit() Get the InputSplit object for a map.
float	getProgress() Get the current progress.
void	incrCounter(Enum key, long amount) Increments the counter identified by the key, which can be of any Enum type, by the specified amount.
void	incrCounter(String group, String counter, long amount) Increments the counter identified by the group and counter name by the specified amount.
void	progress() Report progress to the Hadoop framework.
void	run() The communication thread handles communication with the parent (Task Tracker).
void	setInputSplit(InputSplit split)
void	setProgress(float progress)
void	setStatus(String status) Set the status description for the task.
void	startCommunicationThread()
void	stopCommunicationThread()

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

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

方法详细资料

setStatus

public void setStatus(String status)

从接口复制的说明: Reporter

Set the status description for the task.

指定者:

setStatus 在接口中 Reporter

指定者:

setStatus 在类中 StatusReporter

参数:

status - brief description of the current status.

setProgress

public void setProgress(float progress)

getProgress

public float getProgress()

从类复制的说明: StatusReporter

Get the current progress.

指定者:

getProgress 在接口中 Reporter

指定者:

getProgress 在类中 StatusReporter

返回:

a number between 0.0 and 1.0 (inclusive) indicating the attempt's progress.

progress

public void progress()

从接口复制的说明: Progressable

Report progress to the Hadoop framework.

指定者:

progress 在接口中 Progressable

指定者:

progress 在类中 StatusReporter

getCounter

public Counters.Counter getCounter(String group,
                          String name)

从接口复制的说明: Reporter

Get the Counters.Counter of the given group with the given name.

指定者:

getCounter 在接口中 Reporter

指定者:

getCounter 在类中 StatusReporter

参数:

group - counter group

name - counter name

返回:

the Counter of the given group/name.

getCounter

public Counters.Counter getCounter(Enum<?> name)

从接口复制的说明: Reporter

Get the Counters.Counter of the given group with the given name.

指定者:

getCounter 在接口中 Reporter

指定者:

getCounter 在类中 StatusReporter

参数:

name - counter name

返回:

the Counter of the given group/name.

incrCounter

public void incrCounter(Enum key,
               long amount)

从接口复制的说明: Reporter

Increments the counter identified by the key, which can be of any Enum type, by the specified amount.

指定者:

incrCounter 在接口中 Reporter

参数:

key - key to identify the counter to be incremented. The key can be be any Enum.

amount - A non-negative amount by which the counter is to be incremented.

incrCounter

public void incrCounter(String group,
               String counter,
               long amount)

从接口复制的说明: Reporter

Increments the counter identified by the group and counter name by the specified amount.

指定者:

incrCounter 在接口中 Reporter

参数:

group - name to identify the group of the counter to be incremented.

counter - name to identify the counter within the group.

amount - A non-negative amount by which the counter is to be incremented.

setInputSplit

public void setInputSplit(InputSplit split)

getInputSplit

public InputSplit getInputSplit()
                         throws UnsupportedOperationException

从接口复制的说明: Reporter

Get the InputSplit object for a map.

指定者:

getInputSplit 在接口中 Reporter

返回:

the InputSplit that the map is reading from.

抛出:

UnsupportedOperationException - if called outside a mapper

run

public void run()

The communication thread handles communication with the parent (Task Tracker). It sends progress updates if progress has been made or if the task needs to let the parent know that it's alive. It also pings the parent to see if it's alive.

指定者:

run 在接口中 Runnable

startCommunicationThread

public void startCommunicationThread()

stopCommunicationThread

public void stopCommunicationThread()
                             throws InterruptedException

抛出:

InterruptedException