com.alibaba.schedulerx.worker.processor

接口 JobProcessor

所有超级接口:

BaseProcessor

所有已知实现类:

GoProcessor, JavaProcessor, MapJobProcessor, MapReduceJobProcessor, PythonProcessor, ShellProcessor, StreamJobProcessor, TestBroadcastJobProcessor, TestGridJobProcessor, TestMapReduceJobProcessor, TestParallelJobProcessor, TestSimpleJobExceptionProcessor, TestSimpleJobFailProcessor, TestSimpleJobProcessor, TestSimpleJobProcessorWithKill

public interface JobProcessor
extends BaseProcessor

作者:

xiaomeng.hxm

方法概要

限定符和类型	方法和说明
void	kill(JobContext context)
ProcessResult	postProcess(JobContext context)
void	preProcess(JobContext context)
ProcessResult	process(JobContext context)

方法详细资料

preProcess

void preProcess(JobContext context)
         throws Exception

抛出:

Exception

process

ProcessResult process(JobContext context)
               throws Exception

抛出:

Exception

postProcess

ProcessResult postProcess(JobContext context)

kill

void kill(JobContext context)