From e05bc9067ffdcf6d912857ed252d61ca11100852 Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Fri, 14 Jun 2024 23:32:29 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95map=20reduce?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../snailjob/job/MapReduceJobExecutor.java    | 36 +++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 src/main/java/com/example/snailjob/job/MapReduceJobExecutor.java

diff --git a/src/main/java/com/example/snailjob/job/MapReduceJobExecutor.java b/src/main/java/com/example/snailjob/job/MapReduceJobExecutor.java
new file mode 100644
index 0000000..56b9172
--- /dev/null
+++ b/src/main/java/com/example/snailjob/job/MapReduceJobExecutor.java
@@ -0,0 +1,36 @@
+package com.example.snailjob.job;
+
+import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.job.core.dto.MapReduceArgs;
+import com.aizuda.snailjob.client.job.core.executor.AbstractMapReduceExecutor;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import com.aizuda.snailjob.common.core.constant.SystemConstants;
+import com.aizuda.snailjob.common.core.model.JobContext;
+import com.google.common.collect.Lists;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author: opensnail
+ * @date : 2024-06-13
+ * @since : sj_1.1.0
+ */
+@Component
+public class MapReduceJobExecutor extends AbstractMapReduceExecutor {
+
+    @Override
+    public ExecuteResult doJobExecute(final MapReduceArgs mapReduceArgs) {
+        if (mapReduceArgs.getMapName().equals(SystemConstants.MAP_ROOT)) {
+            doMapExecute(Lists.newArrayList(Lists.newArrayList(1, 2, 3), Lists.newArrayList(4, 5, 6)),
+                "TWO_MAP");
+            return ExecuteResult.success();
+        } else {
+            return ExecuteResult.success(1);
+        }
+
+    }
+
+    @Override
+    protected ExecuteResult doReduceExecute(final JobContext jobContext, final JobArgs jobArgs) {
+        return null;
+    }
+}