public interface Reporter
A facility for Map-Reduce applications to report progress and update counters, status information etc.
Mapper
and Reducer
can use the Reporter
provided to report progress or just indicate that they are alive. In scenarios where the application takes an insignificant 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
static Reporter
NULL
static final Reporter NULL
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 name
Counter
of the given group/name.
Counters.Counter getCounter(String group, String name)
Counters.Counter
of the given group with the given name.
group
- counter group
name
- counter name
Counter
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 mapper
float getProgress()
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4