com.alibaba.schedulerx.worker.processor

类 MapReduceJobProcessor

java.lang.Object

com.alibaba.schedulerx.worker.processor.JavaProcessor

com.alibaba.schedulerx.worker.processor.MapJobProcessor

com.alibaba.schedulerx.worker.processor.MapReduceJobProcessor

所有已实现的接口:

BaseProcessor, JobProcessor, JobProcessorEx

直接已知子类:

TestMapReduceJobProcessor

public abstract class MapReduceJobProcessor
extends MapJobProcessor

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
MapReduceJobProcessor()

方法概要

限定符和类型	方法和说明
ProcessResult	postProcess(JobContext context) 已过时。
abstract ProcessResult	reduce(JobContext context)
boolean	runReduceIfFail(JobContext context)

从类继承的方法 com.alibaba.schedulerx.worker.processor.MapJobProcessor

isRootTask, map

从类继承的方法 com.alibaba.schedulerx.worker.processor.JavaProcessor

kill, preProcess, process

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

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

构造器详细资料

MapReduceJobProcessor

public MapReduceJobProcessor()

方法详细资料

reduce

public abstract ProcessResult reduce(JobContext context)
                              throws Exception

抛出:

Exception

postProcess

@Deprecated
public ProcessResult postProcess(JobContext context)

已过时。

指定者:

postProcess 在接口中 JobProcessorEx

覆盖:

postProcess 在类中 JavaProcessor

runReduceIfFail

public boolean runReduceIfFail(JobContext context)