org.apache.hadoop.mapred

类 Task.OldCombinerRunner<K,V>

java.lang.Object

org.apache.hadoop.mapred.Task.CombinerRunner<K,V>

org.apache.hadoop.mapred.Task.OldCombinerRunner<K,V>

封闭类:

Task

protected static class Task.OldCombinerRunner<K,V>
extends Task.CombinerRunner<K,V>

字段概要

从类继承的字段 org.apache.hadoop.mapred.Task.CombinerRunner

inputCounter, job, reporter

构造器概要

构造器

限定符	构造器和说明
protected	Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls, JobConf conf, Counters.Counter inputCounter, Task.TaskReporter reporter)

方法概要

方法

限定符和类型	方法和说明
protected void	combine(RawKeyValueIterator kvIter, OutputCollector<K,V> combineCollector) Run the combiner over a set of inputs.

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

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

构造器详细资料

Task.OldCombinerRunner

protected Task.OldCombinerRunner(Class<? extends Reducer<K,V,K,V>> cls,
                      JobConf conf,
                      Counters.Counter inputCounter,
                      Task.TaskReporter reporter)

方法详细资料

combine

protected void combine(RawKeyValueIterator kvIter,
           OutputCollector<K,V> combineCollector)
                throws IOException

从类复制的说明: Task.CombinerRunner

Run the combiner over a set of inputs.

参数:

kvIter - the key/value pairs to use as input

combineCollector - the output collector

抛出:

IOException