edu.rice.hj.runtime.mapreduce2

Class Aggregator<K2,V2>

java.lang.Object

edu.rice.hj.runtime.mapreduce2.Aggregator<K2,V2>

public final class Aggregator<K2,V2>
extends Object

Aggregator class.

Author:

Shams Imam (shams@rice.edu)

Constructor Summary

Constructors

Constructor and Description
Aggregator(int numReduceTasks) Constructor for Aggregator.

Method Summary

Modifier and Type	Method and Description
void	emit(K2 inKey, V2 inValue) emit.
protected Map<K2,List<V2>>	intermediates(int reducerId) intermediates.

Methods inherited from class java.lang.Object

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

Constructor Detail

Aggregator

public Aggregator(int numReduceTasks)

Constructor for Aggregator.

Parameters:

numReduceTasks - a int.

Method Detail

emit

public void emit(K2 inKey,
                 V2 inValue)

emit.

Parameters:

inKey - a K2 object.

inValue - a V2 object.

intermediates

protected Map<K2,List<V2>> intermediates(int reducerId)

intermediates.

Parameters:

reducerId - a int.

Returns:

a Map object.