org.apache.hadoop.mapreduce.lib.aggregate

クラス ValueAggregatorCombiner<K1 extends WritableComparable<?>,V1 extends Writable>

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<Text,Text,Text,Text>

org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorCombiner<K1,V1>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class ValueAggregatorCombiner<K1 extends WritableComparable<?>,V1 extends Writable>
extends Reducer<Text,Text,Text,Text>

This class implements the generic combiner of Aggregate.

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ValueAggregatorCombiner()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	reduce(Text key, Iterable<Text> values, org.apache.hadoop.mapreduce.Reducer.Context context) Combines values for a given key.

クラスから継承されたメソッド org.apache.hadoop.mapreduce.Reducer

cleanup, run, setup

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

ValueAggregatorCombiner

public ValueAggregatorCombiner()

メソッドの詳細

reduce

public void reduce(Text key,
                   Iterable<Text> values,
                   org.apache.hadoop.mapreduce.Reducer.Context context)
            throws IOException,
                   InterruptedException

Combines values for a given key.

オーバーライド:

reduce クラス内 Reducer<Text,Text,Text,Text>

パラメータ:

key - the key is expected to be a Text object, whose prefix indicates the type of aggregation to aggregate the values.

values - the values to combine

context - to collect combined values

例外:

IOException

InterruptedException