com.alibaba.schedulerx.worker.processor

类 ShellProcessor

java.lang.Object

com.alibaba.schedulerx.worker.processor.ShellProcessor

所有已实现的接口:

BaseProcessor, JobProcessor

直接已知子类:

GoProcessor, PythonProcessor

public class ShellProcessor
extends Object
implements JobProcessor

作者:

xiaomeng.hxm

字段概要

字段

限定符和类型	字段和说明
protected static Logger	LOGGER

构造器概要

构造器

构造器和说明
ShellProcessor()

方法概要

限定符和类型	方法和说明
protected String[]	getContent(JobContext context)
void	kill(JobContext context)
ProcessResult	postProcess(JobContext context)
void	preProcess(JobContext context)
ProcessResult	process(JobContext context)
protected void	processStdErrorStream(InputStream inputStream)
protected void	processStdOutputStream(InputStream inputStream)
protected boolean	redirectStream()

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

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

字段详细资料

LOGGER

protected static final Logger LOGGER

构造器详细资料

ShellProcessor

public ShellProcessor()

方法详细资料

process

public ProcessResult process(JobContext context)

指定者:

process 在接口中 JobProcessor

getContent

protected String[] getContent(JobContext context)

processStdOutputStream

protected void processStdOutputStream(InputStream inputStream)

processStdErrorStream

protected void processStdErrorStream(InputStream inputStream)

redirectStream

protected boolean redirectStream()

postProcess

public ProcessResult postProcess(JobContext context)

指定者:

postProcess 在接口中 JobProcessor

kill

public void kill(JobContext context)

指定者:

kill 在接口中 JobProcessor

preProcess

public void preProcess(JobContext context)
                throws Exception

指定者:

preProcess 在接口中 JobProcessor

抛出:

Exception