mapreduce/Reducer.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

package mapreduce;

import java.util.List;
import java.util.concurrent.RecursiveTask;

/**
 *
 * @author mph
 * @param <K>   key
 * @param <V>   valueListumulator
 * @param <OUT> output value
 */
public abstract class Reducer<K, V, OUT> extends RecursiveTask<OUT> {

  protected K key;
  protected List<V> valueList;

  /**
   * @param aKey  key for this reducer
   * @param aList list of values
   */
  public void setInput(K aKey, List<V> aList) {
    key = aKey;
    valueList = aList;
  }
};