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); }