@InterfaceAudience.Public @InterfaceStability.Stable public interface Reporter extends Progressable
Mapper
and Reducer
can use the Reporter
provided to report progress or just indicate that they are alive. In
scenarios where the application takes significant amount of time to
process individual key/value pairs, this is crucial since the framework
might assume that the task has timed-out and kill that task.
Applications can also update Counters
via the provided
Reporter
.
Progressable
,
Counters
Modifier and Type | Field and Description |
---|---|
static Reporter |
NULL
A constant of Reporter type that does nothing.
|
Modifier and Type | Method and Description |
---|---|
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 progress of the task.
|
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 |
setStatus(String status)
Set the status description for the task.
|
progress
void setStatus(String status)
status
- brief description of the current status.Counters.Counter getCounter(Enum<?> name)
Counters.Counter
of the given group with the given name.name
- counter nameCounter
of the given group/name.Counters.Counter getCounter(String group, String name)
Counters.Counter
of the given group with the given name.group
- counter groupname
- counter nameCounter
of the given group/name.void incrCounter(Enum<?> key, long amount)
Enum
type, by the specified amount.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.void incrCounter(String group, String counter, long amount)
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.InputSplit getInputSplit() throws UnsupportedOperationException
InputSplit
object for a map.InputSplit
that the map is reading from.UnsupportedOperationException
- if called outside a mapperfloat getProgress()
Copyright © 2015 Apache Software Foundation. All rights reserved.