com.alibaba.schedulerx.worker.processor

类 StreamJobProcessor

java.lang.Object

com.alibaba.schedulerx.worker.processor.JavaProcessor

com.alibaba.schedulerx.worker.processor.StreamJobProcessor

所有已实现的接口:

BaseProcessor, JobProcessor, JobProcessorEx

public abstract class StreamJobProcessor
extends JavaProcessor

作者:

xiaomeng.hxm

构造器概要

构造器

构造器和说明
StreamJobProcessor()

方法概要

限定符和类型	方法和说明
abstract void	consume()
abstract void	produce()

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

kill, postProcess, preProcess, process

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

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

构造器详细资料

StreamJobProcessor

public StreamJobProcessor()

方法详细资料

produce

public abstract void produce()

consume

public abstract void consume()