com.github.kfcfans.powerjob.worker.core.processor.sdk

类 MapProcessor

java.lang.Object

com.github.kfcfans.powerjob.worker.core.processor.sdk.MapProcessor

所有已实现的接口:

BasicProcessor

直接已知子类:

MapReduceProcessor

public abstract class MapProcessor
extends Object
implements BasicProcessor

Map 处理器，允许开发者自定义拆分任务进行分布式执行

从以下版本开始:

2020/4/17

作者:

tjq

构造器概要

构造器

构造器和说明
MapProcessor()

方法概要

限定符和类型	方法和说明
boolean	isRootTask() 是否为根任务
ProcessResult	map(List<?> taskList, String taskName) 分发子任务

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.github.kfcfans.powerjob.worker.core.processor.sdk.BasicProcessor

process

构造器详细资料

MapProcessor

public MapProcessor()

方法详细资料

map

public ProcessResult map(List<?> taskList,
                         String taskName)

分发子任务

参数:

taskList - 子任务，再次执行时可通过 TaskContext#getSubTask 获取

taskName - 子任务名称，即子任务处理器中 TaskContext#getTaskName 获取到的值

返回:

map结果

isRootTask

public boolean isRootTask()

是否为根任务

返回:

true -> 根任务 / false -> 非根任务