gtsoft/gtsoft-snail-job-demo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

调试map

Browse Source
This commit is contained in:
byteblogs168 2024-06-26 23:41:54 +08:00
parent 2e6503f403
commit 550e263d99
2 changed files with 26 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/main/java/com/example/snailjob/job/TestAnnoMapJobExecutor.java
View File

@ -3,11 +3,7 @@ package com.example.snailjob.job;
import com.aizuda.snailjob.client.job.core.MapHandler;
import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
import com.aizuda.snailjob.client.job.core.annotation.MapExecutor;
import com.aizuda.snailjob.client.job.core.annotation.MergeReduceExecutor;
import com.aizuda.snailjob.client.job.core.annotation.ReduceExecutor;
import com.aizuda.snailjob.client.job.core.dto.MapArgs;
import com.aizuda.snailjob.client.job.core.dto.MergeReduceArgs;
import com.aizuda.snailjob.client.job.core.dto.ReduceArgs;
import com.aizuda.snailjob.client.model.ExecuteResult;
import com.google.common.collect.Lists;
import org.springframework.stereotype.Component;
@ -20,22 +16,22 @@ import org.springframework.stereotype.Component;
@JobExecutor(name = "testAnnoMapJobExecutor")
public class TestAnnoMapJobExecutor {
// @MapExecutor
// public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
// System.out.println(mapArgs);
// return mapHandler.doMap(Lists.newArrayList("aaa"), "MONTH_MAP");
// }
//
// @MapExecutor(taskName = "MONTH_MAP")
// public ExecuteResult monthMapExecute(MapArgs mapArgs) {
// System.out.println(mapArgs);
// return ExecuteResult.success(123);
// }
//
// @MapExecutor(taskName = "LAST_MAP")
// public ExecuteResult lastMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
// System.out.println(mapArgs);
// return ExecuteResult.success();
// }
@MapExecutor
public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
System.out.println(mapArgs);
return mapHandler.doMap(Lists.newArrayList("1", "2", "3"), "MONTH_MAP");
}
@MapExecutor(taskName = "MONTH_MAP1")
public ExecuteResult monthMapExecute(MapArgs mapArgs) {
System.out.println(mapArgs);
return ExecuteResult.success(123);
}
@MapExecutor(taskName = "LAST_MAP")
public ExecuteResult lastMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
System.out.println(mapArgs);
return ExecuteResult.success();
}
}

12
src/main/java/com/example/snailjob/job/TestAnnoMapReduceJobExecutor.java
View File

@ -9,9 +9,13 @@ import com.aizuda.snailjob.client.job.core.dto.MapArgs;
import com.aizuda.snailjob.client.job.core.dto.MergeReduceArgs;
import com.aizuda.snailjob.client.job.core.dto.ReduceArgs;
import com.aizuda.snailjob.client.model.ExecuteResult;
import com.aizuda.snailjob.common.core.util.JsonUtil;
import com.google.common.collect.Lists;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.stream.Collectors;
/**
* @author: opensnail
* @date : 2024-06-26
@ -23,13 +27,14 @@ public class TestAnnoMapReduceJobExecutor {
@MapExecutor
public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler mapHandler) {
System.out.println(mapArgs);
return mapHandler.doMap(Lists.newArrayList("aaa"), "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);
return ExecuteResult.success(123);
String mapResult = mapArgs.getMapResult();
return ExecuteResult.success(mapResult);
}
@MapExecutor(taskName = "LAST_MAP")
@ -41,7 +46,8 @@ public class TestAnnoMapReduceJobExecutor {
@ReduceExecutor
public ExecuteResult reduceExecute(ReduceArgs mapReduceArgs) {
System.out.println(mapReduceArgs);
return ExecuteResult.success();
List<String> mapResult = (List<String>) mapReduceArgs.getMapResult();
return ExecuteResult.success(mapResult.stream().map(Integer::parseInt).mapToInt(Integer::intValue).sum());
}
/**