org.apache.hadoop.mapred

类 Task.CombineOutputCollector<K,V>

java.lang.Object

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

所有已实现的接口:

OutputCollector<K,V>

封闭类:

Task

protected static class Task.CombineOutputCollector<K,V>
extends Object
implements OutputCollector<K,V>

OutputCollector for the combiner.

构造器概要

构造器

构造器和说明
Task.CombineOutputCollector(Counters.Counter outCounter, Progressable progressable, Configuration conf)

方法概要

方法

限定符和类型	方法和说明
void	collect(K key, V value) Adds a key/value pair to the output.
void	setWriter(IFile.Writer<K,V> writer)

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

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

构造器详细资料

Task.CombineOutputCollector

public Task.CombineOutputCollector(Counters.Counter outCounter,
                           Progressable progressable,
                           Configuration conf)

方法详细资料

setWriter

public void setWriter(IFile.Writer<K,V> writer)

collect

public void collect(K key,
           V value)
             throws IOException

从接口复制的说明: OutputCollector

Adds a key/value pair to the output.

指定者:

collect 在接口中 OutputCollector<K,V>

参数:

key - the key to collect.

value - to value to collect.

抛出:

IOException