From b170277f0f0677b3bfabca6c48fe06ce5ffec3cb Mon Sep 17 00:00:00 2001
From: byteblogs168 <598092184@qq.com>
Date: Thu, 27 Jun 2024 11:02:53 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96Map=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E7=94=A8=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../job/TestAnnoMapReduceJobExecutor.java     | 26 ++++++++++---------
 1 file changed, 14 insertions(+), 12 deletions(-)

diff --git a/src/main/java/com/example/snailjob/job/TestAnnoMapReduceJobExecutor.java b/src/main/java/com/example/snailjob/job/TestAnnoMapReduceJobExecutor.java
index 34158b7..06c42cf 100644
--- a/src/main/java/com/example/snailjob/job/TestAnnoMapReduceJobExecutor.java
+++ b/src/main/java/com/example/snailjob/job/TestAnnoMapReduceJobExecutor.java
@@ -27,27 +27,24 @@ public class TestAnnoMapReduceJobExecutor {
     @MapExecutor
     public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
         System.out.println(mapArgs);
-        return mapHandler.doMap(Lists.newArrayList(1, 2, 3, 4, 5, 6), "MONTH_MAP");
+        return mapHandler.doMap(Lists.newArrayList("1", "2", "3", "4", "5", "6"), "MONTH_MAP");
     }
 
     @MapExecutor(taskName = "MONTH_MAP")
     public ExecuteResult monthMapExecute(MapArgs mapArgs) {
         System.out.println(mapArgs);
-        String mapResult = mapArgs.getMapResult();
-        return ExecuteResult.success(mapResult);
-    }
-
-    @MapExecutor(taskName = "LAST_MAP")
-    public ExecuteResult lastMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
-        System.out.println(mapArgs);
-        return ExecuteResult.success();
+        return ExecuteResult.success(Integer.parseInt((String) mapArgs.getMapResult()) * 2);
     }
 
     @ReduceExecutor
     public ExecuteResult reduceExecute(ReduceArgs mapReduceArgs) {
         System.out.println(mapReduceArgs);
-        List<String> mapResult = (List<String>) mapReduceArgs.getMapResult();
-        return ExecuteResult.success(mapResult.stream().map(Integer::parseInt).mapToInt(Integer::intValue).sum());
+        return ExecuteResult.success(
+            mapReduceArgs.getMapResult()
+                .stream()
+                .map(String::valueOf)
+                .map(Integer::parseInt)
+                .mapToInt(Integer::intValue).sum());
     }
 
     /**
@@ -56,6 +53,11 @@ public class TestAnnoMapReduceJobExecutor {
     @MergeReduceExecutor
     public ExecuteResult mergeReduceExecute(MergeReduceArgs mergeReduceArgs) {
         System.out.println(mergeReduceArgs);
-        return ExecuteResult.success();
+        return ExecuteResult.success(
+            mergeReduceArgs.getReduces()
+                .stream()
+                .map(String::valueOf)
+                .map(Integer::parseInt)
+                .mapToInt(Integer::intValue).sum());
     }
 }