com.espertech.esper.dataflow.core

Class EPDataFlowEmitter1Stream1TargetBase

java.lang.Object

com.espertech.esper.dataflow.core.EPDataFlowEmitter1Stream1TargetBase

All Implemented Interfaces:

SubmitHandler, EPDataFlowEmitter

Direct Known Subclasses:

EPDataFlowEmitter1Stream1TargetPassAlong, EPDataFlowEmitter1Stream1TargetUnwind

public abstract class EPDataFlowEmitter1Stream1TargetBase
extends Object
implements EPDataFlowEmitter, SubmitHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected EPDataFlowEmitterExceptionHandler	exceptionHandler
protected net.sf.cglib.reflect.FastMethod	fastMethod
protected int	operatorNum
protected SignalHandler	signalHandler
protected DataFlowSignalManager	signalManager
protected Object	targetObject

Constructor Summary

Constructors

Constructor and Description
EPDataFlowEmitter1Stream1TargetBase(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, EngineImportService engineImportService)

Method Summary

Modifier and Type	Method and Description
net.sf.cglib.reflect.FastMethod	getFastMethod()
void	handleSignal(EPDataFlowSignal signal)
void	submit(Object object)
abstract void	submitInternal(Object object)
void	submitPort(int portNumber, Object object)
void	submitSignal(EPDataFlowSignal signal)

Methods inherited from class java.lang.Object

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

Field Detail

operatorNum

protected final int operatorNum

signalManager

protected final DataFlowSignalManager signalManager

signalHandler

protected final SignalHandler signalHandler

exceptionHandler

protected final EPDataFlowEmitterExceptionHandler exceptionHandler

fastMethod

protected final net.sf.cglib.reflect.FastMethod fastMethod

targetObject

protected final Object targetObject

Constructor Detail

EPDataFlowEmitter1Stream1TargetBase

public EPDataFlowEmitter1Stream1TargetBase(int operatorNum,
                                           DataFlowSignalManager signalManager,
                                           SignalHandler signalHandler,
                                           EPDataFlowEmitterExceptionHandler exceptionHandler,
                                           ObjectBindingPair target,
                                           EngineImportService engineImportService)

Method Detail

submitInternal

public abstract void submitInternal(Object object)

Specified by:

submitInternal in interface SubmitHandler

submit

public void submit(Object object)

Specified by:

submit in interface EPDataFlowEmitter

submitSignal

public void submitSignal(EPDataFlowSignal signal)

Specified by:

submitSignal in interface EPDataFlowEmitter

handleSignal

public void handleSignal(EPDataFlowSignal signal)

Specified by:

handleSignal in interface SubmitHandler

submitPort

public void submitPort(int portNumber,
                       Object object)

Specified by:

submitPort in interface EPDataFlowEmitter

getFastMethod

public net.sf.cglib.reflect.FastMethod getFastMethod()

Specified by:

getFastMethod in interface SubmitHandler