From cb491e82b5ce3dcb7e3c41973a46cb7dcbaa9008 Mon Sep 17 00:00:00 2001
From: "github-classroom[bot]"
 <66690702+github-classroom[bot]@users.noreply.github.com>
Date: Sun, 10 Dec 2023 19:07:21 +0000
Subject: Initial commit

---
 mapreduce/Reducer.java | 26 ++++++++++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 mapreduce/Reducer.java

(limited to 'mapreduce/Reducer.java')

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;
+  }
+};
-- 
cgit v1.2.3-70-g09d2