类的使用
com.alibaba.schedulerx.worker.processor.ProcessResult

使用ProcessResult的程序包

程序包	说明
com.alibaba.schedulerx.worker.master
com.alibaba.schedulerx.worker.processor
com.alibaba.schedulerx.worker.processor.demo

com.alibaba.schedulerx.worker.master中ProcessResult的使用

返回ProcessResult的com.alibaba.schedulerx.worker.master中的方法

限定符和类型	方法和说明
ProcessResult	MapTaskMaster.postFinish(long jobInstanceId)
ProcessResult	TaskMaster.postFinish(long jobInstanceId)
ProcessResult	ShardingTaskMaster.postFinish(long jobInstanceId)
ProcessResult	BroadcastTaskMaster.postFinish(long jobInstanceId)
ProcessResult	GridTaskMaster.postFinish(long jobInstanceId)

com.alibaba.schedulerx.worker.processor中ProcessResult的使用

返回ProcessResult的com.alibaba.schedulerx.worker.processor中的方法

限定符和类型	方法和说明
ProcessResult	MapJobProcessor.map(List<? extends Object> taskList, String taskName) distribute tasks to all workers.
ProcessResult	JobProcessorEx.postProcess(JobContext context)
ProcessResult	MapReduceJobProcessor.postProcess(JobContext context) 已过时。
ProcessResult	ShellProcessor.postProcess(JobContext context)
ProcessResult	JavaProcessor.postProcess(JobContext context)
ProcessResult	JobProcessorEx.process(JobContext context)
ProcessResult	JobProcessor.process(JobContext context)
ProcessResult	DataWorksProcessor.process(JobContext context)
ProcessResult	ShellProcessor.process(JobContext context)
ProcessResult	JavaProcessor.process(JobContext context)
abstract ProcessResult	MapReduceJobProcessor.reduce(JobContext context)

com.alibaba.schedulerx.worker.processor.demo中ProcessResult的使用

返回ProcessResult的com.alibaba.schedulerx.worker.processor.demo中的方法

限定符和类型	方法和说明
ProcessResult	TestBroadcastJobProcessor.postProcess(JobContext context)
ProcessResult	TestParallelJobProcessor.process(JobContext context)
ProcessResult	TestMapReduceJobProcessor.process(JobContext context)
ProcessResult	TestSimpleJobProcessorWithKill.process(JobContext context)
ProcessResult	TestSimpleJobFailProcessor.process(JobContext context)
ProcessResult	TestGridJobProcessor.process(JobContext context)
ProcessResult	TestBroadcastJobProcessor.process(JobContext context)
ProcessResult	TestSimpleJobProcessor.process(JobContext context)
ProcessResult	TestSimpleJobExceptionProcessor.process(JobContext context)
ProcessResult	TestMapReduceJobProcessor.reduce(JobContext context)