序 本文主要研究一下PowerJob的MapProcessor MapProcessor tech/powerjob/worker/core/processor/sdk/MapProcessor.java public interface MapProcessor extends BasicProcessor { Logger log = LoggerFactory.getLogger(MapProcessor.class); int RECOMMEND_BATCH_SIZE = 200; /** * 分发子任务 * @param taskList 子任务，再次执行时可通过 TaskContext#getSubTask 获取 * @param taskName 子任务名称，即子任务处理器中 TaskContext#getTaskName 获取到的值 * @throws PowerJobCheckedException map 失败将抛出异常 */ default void map(List<?> taskList, String taskName) throws...
