From 3bb60dc80ad0750c2672ac6a04b1cea0608e6d7c Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Thu, 27 Jun 2024 22:42:13 +0800 Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.1.0-beta2):=20=E4=BC=98=E5=8C=96Map?= =?UTF-8?q?Handler?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../aizuda/snailjob/client/job/core/MapHandler.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/MapHandler.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/MapHandler.java index a264c8a6..6e0732e8 100644 --- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/MapHandler.java +++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/MapHandler.java @@ -9,7 +9,14 @@ import java.util.List; * @date : 2024-06-26 * @version : sj_1.1.0 */ -public interface MapHandler { +public interface MapHandler { - ExecuteResult doMap(List taskList, String nextTaskName); + /** + * 执行MAP操作 + * + * @param taskList 需要分片的集合(建议不超过200个, 超过500禁止分片.) + * @param nextTaskName 下一次需要处理MAP的节点名称 (不能是MAP_ROOT) + * @return ExecuteResult + */ + ExecuteResult doMap(List taskList, String nextTaskName); }