com.alibaba.schedulerx.worker.processor

类 MapJobProcessor

java.lang.Object

com.alibaba.schedulerx.worker.processor.JavaProcessor

com.alibaba.schedulerx.worker.processor.MapJobProcessor

所有已实现的接口:

BaseProcessor, JobProcessor, JobProcessorEx

直接已知子类:

MapReduceJobProcessor, TestGridJobProcessor, TestParallelJobProcessor

public abstract class MapJobProcessor
extends JavaProcessor

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
MapJobProcessor()

方法概要

限定符和类型	方法和说明
protected boolean	isRootTask(JobContext context)
ProcessResult	map(List<? extends Object> taskList, String taskName) distribute tasks to all workers.

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

kill, postProcess, preProcess, process

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

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

构造器详细资料

MapJobProcessor

public MapJobProcessor()

方法详细资料

map

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

distribute tasks to all workers.

参数:

taskList, - every element in taskList shoudn't beyond 64KB

taskName -

返回:

isRootTask

protected boolean isRootTask(JobContext context)