org.apache.hadoop.mapreduce.lib.aggregate

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

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<K1,V1,Text,Text>

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

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

This class implements the generic mapper of Aggregate.

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

コンストラクタ

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

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	map(K1 key, V1 value, org.apache.hadoop.mapreduce.Mapper.Context context) the map function.
void	setup(org.apache.hadoop.mapreduce.Mapper.Context context) Called once at the beginning of the task.

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

cleanup, run

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

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

コンストラクタの詳細

ValueAggregatorMapper

public ValueAggregatorMapper()

メソッドの詳細

setup

public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException,
                  InterruptedException

クラスからコピーされた説明: Mapper

Called once at the beginning of the task.

オーバーライド:

setup クラス内 Mapper<K1 extends WritableComparable<?>,V1 extends Writable,Text,Text>

例外:

IOException

InterruptedException

map

public void map(K1 key,
                V1 value,
                org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException,
                InterruptedException

the map function. It iterates through the value aggregator descriptor list to generate aggregation id/value pairs and emit them.

オーバーライド:

map クラス内 Mapper<K1 extends WritableComparable<?>,V1 extends Writable,Text,Text>

例外:

IOException

InterruptedException