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

类 MapReduceProcessor

java.lang.Object

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

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

所有已实现的接口:

BasicProcessor

public abstract class MapReduceProcessor
extends MapProcessor

MapReduce执行处理器，适用于MapReduce任务 在 MapProcessor 的基础上添加了结果汇集（reduce）的方法

从以下版本开始:

2020/3/18

作者:

tjq

构造器概要

构造器

构造器和说明
MapReduceProcessor()

方法概要

限定符和类型	方法和说明
abstract ProcessResult	reduce(TaskContext context, List<TaskResult> taskResults) reduce方法将在所有任务结束后调用

从类继承的方法 com.github.kfcfans.powerjob.worker.core.processor.sdk.MapProcessor

isRootTask, map

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

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

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

process

构造器详细资料

MapReduceProcessor

public MapReduceProcessor()

方法详细资料

reduce

public abstract ProcessResult reduce(TaskContext context,
                                     List<TaskResult> taskResults)

reduce方法将在所有任务结束后调用

参数:

context - 任务上下文

taskResults - 保存了各个子Task的执行结果

返回:

reduce产生的结果将作为任务最终的返回结果