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/Mapper.java | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 mapreduce/Mapper.java (limited to 'mapreduce/Mapper.java') diff --git a/mapreduce/Mapper.java b/mapreduce/Mapper.java new file mode 100644 index 0000000..c2da326 --- /dev/null +++ b/mapreduce/Mapper.java @@ -0,0 +1,22 @@ +package mapreduce; + +import java.util.Map; +import java.util.concurrent.RecursiveTask; + +/** + * + * @author mph + * @param input type + * @param key type + * @param accumulator type + */ +public abstract class Mapper extends RecursiveTask> { + protected IN input; + + /** + * @param anInput list of input items + */ + public void setInput(IN anInput) { + input = anInput; + } +} -- cgit v1.2.3-70-g09d2