| 程序包 | 说明 |
|---|---|
| com.github.kfcfans.powerjob.worker.core.processor.built | |
| com.github.kfcfans.powerjob.worker.core.processor.sdk |
| 限定符和类型 | 方法和说明 |
|---|---|
ProcessResult |
ScriptProcessor.process(TaskContext context) |
| 限定符和类型 | 方法和说明 |
|---|---|
static ProcessResult |
BroadcastProcessor.defaultResult(List<TaskResult> taskResults) |
ProcessResult |
MapProcessor.map(List<?> taskList,
String taskName)
分发子任务
|
ProcessResult |
BroadcastProcessor.postProcess(TaskContext context,
List<TaskResult> taskResults)
在所有节点广播执行完成后执行,只会在一台机器执行一次
|
ProcessResult |
BroadcastProcessor.preProcess(TaskContext context)
在所有节点广播执行前执行,只会在一台机器执行一次
|
ProcessResult |
BasicProcessor.process(TaskContext context)
核心处理逻辑
|
abstract ProcessResult |
MapReduceProcessor.reduce(TaskContext context,
List<TaskResult> taskResults)
reduce方法将在所有任务结束后调用
|
Copyright © 2020. All rights reserved.