インタフェースの使用
org.apache.hadoop.mapred.OutputCollector

OutputCollectorを使用しているパッケージ

パッケージ	説明
org.apache.hadoop.mapred
org.apache.hadoop.mapred.lib
org.apache.hadoop.mapred.lib.aggregate

org.apache.hadoop.mapredでのOutputCollectorの使用

OutputCollector型のパラメータを持つorg.apache.hadoop.mapredのメソッド

修飾子とタイプ	メソッドと説明
void	Mapper.map(K1 key, V1 value, OutputCollector<K2,V2> output, Reporter reporter) Maps a single input key/value pair into an intermediate key/value pair.
void	Reducer.reduce(K2 key, Iterator<V2> values, OutputCollector<K3,V3> output, Reporter reporter) Reduces values for a given key.
void	MapRunner.run(RecordReader<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)
void	MapRunnable.run(RecordReader<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter) Start mapping input <key, value> pairs.

org.apache.hadoop.mapred.libでのOutputCollectorの使用

OutputCollectorを返すorg.apache.hadoop.mapred.libのメソッド

修飾子とタイプ	メソッドと説明
OutputCollector	MultipleOutputs.getCollector(String namedOutput, Reporter reporter) Gets the output collector for a named output.
OutputCollector	MultipleOutputs.getCollector(String namedOutput, String multiName, Reporter reporter) Gets the output collector for a multi named output.

OutputCollector型のパラメータを持つorg.apache.hadoop.mapred.libのメソッド

修飾子とタイプ	メソッドと説明
void	TokenCountMapper.map(K key, Text value, OutputCollector<Text,LongWritable> output, Reporter reporter)
void	RegexMapper.map(K key, Text value, OutputCollector<Text,LongWritable> output, Reporter reporter)
void	IdentityMapper.map(K key, V val, OutputCollector<K,V> output, Reporter reporter) The identity function.
void	FieldSelectionMapReduce.map(K key, V val, OutputCollector<Text,Text> output, Reporter reporter) The identify function.
void	InverseMapper.map(K key, V value, OutputCollector<V,K> output, Reporter reporter) The inverse function.
void	ChainMapper.map(Object key, Object value, OutputCollector output, Reporter reporter) Chains the map(...)
void	LongSumReducer.reduce(K key, Iterator<LongWritable> values, OutputCollector<K,LongWritable> output, Reporter reporter)
void	IdentityReducer.reduce(K key, Iterator<V> values, OutputCollector<K,V> output, Reporter reporter) Writes all keys and values directly to output.
void	ChainReducer.reduce(Object key, Iterator values, OutputCollector output, Reporter reporter) Chains the reduce(...)
void	FieldSelectionMapReduce.reduce(Text key, Iterator<Text> values, OutputCollector<Text,Text> output, Reporter reporter)
void	MultithreadedMapRunner.run(RecordReader<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)

org.apache.hadoop.mapred.lib.aggregateでのOutputCollectorの使用

OutputCollector型のパラメータを持つorg.apache.hadoop.mapred.lib.aggregateのメソッド

修飾子とタイプ	メソッドと説明
void	ValueAggregatorCombiner.map(K1 arg0, V1 arg1, OutputCollector<Text,Text> arg2, Reporter arg3) Do nothing.
void	ValueAggregatorMapper.map(K1 key, V1 value, OutputCollector<Text,Text> output, Reporter reporter) the map function.
void	ValueAggregatorReducer.map(K1 arg0, V1 arg1, OutputCollector<Text,Text> arg2, Reporter arg3) Do nothing.
void	ValueAggregatorCombiner.reduce(Text key, Iterator<Text> values, OutputCollector<Text,Text> output, Reporter reporter) Combines values for a given key.
void	ValueAggregatorMapper.reduce(Text arg0, Iterator<Text> arg1, OutputCollector<Text,Text> arg2, Reporter arg3) Do nothing.
void	ValueAggregatorReducer.reduce(Text key, Iterator<Text> values, OutputCollector<Text,Text> output, Reporter reporter)