1 files changed, 26 insertions, 0 deletions
diff --git a/mapreduce/Reducer.java b/mapreduce/Reducer.java
new file mode 100644
index 0000000..982ddfc
--- /dev/null
+++ b/mapreduce/Reducer.java
@@ -0,0 +1,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;
+  }
+};