Package | Description |
---|---|
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.
|
Modifier and Type | Field and Description |
---|---|
protected Counters.Counter |
Task.CombinerRunner.inputCounter |
protected Counters.Counter |
Task.spilledRecordsCounter |
Modifier and Type | Method and Description |
---|---|
Counters.Counter |
Counters.Group.addCounter(java.lang.String name,
java.lang.String displayName,
long value) |
Counters.Counter |
Counters.Group.findCounter(java.lang.String counterName) |
Counters.Counter |
Counters.Group.findCounter(java.lang.String counterName,
boolean create) |
Counters.Counter |
Counters.findCounter(java.lang.String group,
int id,
java.lang.String name)
Deprecated.
use
Counters.findCounter(String, String) instead |
Counters.Counter |
Counters.findCounter(java.lang.String group,
java.lang.String name)
Deprecated.
|
Counters.Counter |
Counters.Group.findCounter(java.lang.String counterName,
java.lang.String displayName) |
Counters.Counter |
Task.TaskReporter.getCounter(java.lang.Enum<?> name) |
Counters.Counter |
Reporter.getCounter(java.lang.Enum<?> name)
Get the
Counters.Counter of the given group with the given name. |
Counters.Counter |
Counters.Group.getCounter(int id,
java.lang.String name)
Deprecated.
use
Counters.Group.findCounter(String) instead |
Counters.Counter |
Task.TaskReporter.getCounter(java.lang.String group,
java.lang.String name) |
Counters.Counter |
Reporter.getCounter(java.lang.String group,
java.lang.String name)
Get the
Counters.Counter of the given group with the given name. |
Counters.Counter |
Counters.Group.getCounterForName(java.lang.String name)
Get the counter for the given name and create it if it doesn't exist.
|
Modifier and Type | Method and Description |
---|---|
CounterGroupBase<Counters.Counter> |
Counters.Group.getUnderlyingGroup() |
java.util.Iterator<Counters.Counter> |
Counters.Group.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
Counters.Group.addCounter(Counters.Counter counter) |
boolean |
Counters.Counter.contentEquals(Counters.Counter counter)
Deprecated.
|
static <K,V> Task.CombinerRunner<K,V> |
Task.CombinerRunner.create(JobConf job,
TaskAttemptID taskId,
Counters.Counter inputCounter,
Task.TaskReporter reporter,
OutputCommitter committer) |
Modifier and Type | Method and Description |
---|---|
void |
Counters.Group.incrAllCounters(CounterGroupBase<Counters.Counter> rightGroup) |
Constructor and Description |
---|
Task.CombineOutputCollector(Counters.Counter outCounter,
org.apache.hadoop.util.Progressable progressable,
org.apache.hadoop.conf.Configuration conf) |
Task.CombineValuesIterator(RawKeyValueIterator in,
org.apache.hadoop.io.RawComparator<KEY> comparator,
java.lang.Class<KEY> keyClass,
java.lang.Class<VALUE> valClass,
org.apache.hadoop.conf.Configuration conf,
Reporter reporter,
Counters.Counter combineInputCounter) |
Task.OldCombinerRunner(java.lang.Class<? extends Reducer<K,V,K,V>> cls,
JobConf conf,
Counters.Counter inputCounter,
Task.TaskReporter reporter) |
Copyright © 2009 The Apache Software Foundation