类的使用
com.alibaba.schedulerx.worker.domain.JobContext

使用JobContext的程序包

程序包	说明
com.alibaba.schedulerx.worker.container
com.alibaba.schedulerx.worker.domain
com.alibaba.schedulerx.worker.processor
com.alibaba.schedulerx.worker.processor.demo
com.alibaba.schedulerx.worker.pull
com.alibaba.schedulerx.worker.util

com.alibaba.schedulerx.worker.container中JobContext的使用

返回JobContext的com.alibaba.schedulerx.worker.container中的方法

限定符和类型	方法和说明
JobContext	ThreadContainer.getContext()
JobContext	ThreadContainerPool.getContext()
abstract JobContext	ContainerPool.getContext()

参数类型为JobContext的com.alibaba.schedulerx.worker.container中的方法

限定符和类型	方法和说明
static Container	ContainerFactory.create(JobContext context)
void	ThreadContainer.setContext(JobContext context)
void	ThreadContainerPool.setContext(JobContext jobContext)
abstract void	ContainerPool.setContext(JobContext jobContext)

参数类型为JobContext的com.alibaba.schedulerx.worker.container中的构造器

构造器和说明
ActorContainer(JobContext context)
DockerContainer(JobContext context)
ProcessContainer(JobContext context)
ThreadContainer(JobContext context, ContainerPool containerPool)

com.alibaba.schedulerx.worker.domain中JobContext的使用

返回JobContext的com.alibaba.schedulerx.worker.domain中的方法

限定符和类型	方法和说明
JobContext	JobContext.JobContextBuilder.build()

参数类型为JobContext的com.alibaba.schedulerx.worker.domain中的方法

限定符和类型	方法和说明
static JobContext.JobContextBuilder	JobContext.newBuilder(JobContext context)

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

参数类型为JobContext的com.alibaba.schedulerx.worker.processor中的方法

限定符和类型	方法和说明
protected String[]	PythonProcessor.getContent(JobContext context)
protected String[]	GoProcessor.getContent(JobContext context)
protected String[]	ShellProcessor.getContent(JobContext context)
protected boolean	MapJobProcessor.isRootTask(JobContext context)
void	JobProcessor.kill(JobContext context)
void	ShellProcessor.kill(JobContext context)
void	JavaProcessor.kill(JobContext context)
ProcessResult	JobProcessor.postProcess(JobContext context)
ProcessResult	MapReduceJobProcessor.postProcess(JobContext context) 已过时。
ProcessResult	ShellProcessor.postProcess(JobContext context)
ProcessResult	JavaProcessor.postProcess(JobContext context)
void	JobProcessor.preProcess(JobContext context)
void	PythonProcessor.preProcess(JobContext context)
void	GoProcessor.preProcess(JobContext context)
void	ShellProcessor.preProcess(JobContext context)
void	JavaProcessor.preProcess(JobContext context)
ProcessResult	JobProcessor.process(JobContext context)
ProcessResult	ShellProcessor.process(JobContext context)
abstract ProcessResult	MapReduceJobProcessor.reduce(JobContext context)
boolean	MapReduceJobProcessor.runReduceIfFail(JobContext context)

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

参数类型为JobContext的com.alibaba.schedulerx.worker.processor.demo中的方法

限定符和类型	方法和说明
void	TestSimpleJobProcessorWithKill.kill(JobContext context)
ProcessResult	TestBroadcastJobProcessor.postProcess(JobContext context)
void	TestSimpleJobProcessorWithKill.preProcess(JobContext context)
void	TestBroadcastJobProcessor.preProcess(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)

com.alibaba.schedulerx.worker.pull中JobContext的使用

参数类型为JobContext的com.alibaba.schedulerx.worker.pull中的构造器

构造器和说明
ConsumerThread(JobContext context, ContainerPool containerPool)

com.alibaba.schedulerx.worker.util中JobContext的使用

返回JobContext的com.alibaba.schedulerx.worker.util中的方法

限定符和类型	方法和说明
static JobContext	ContanerUtil.convert2JobContext(com.alibaba.schedulerx.protocol.Worker.MasterStartContainerRequest request)