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 java.lang.Object
implements EPDataFlowEmitter, SubmitHandler

Field Summary

protected EPDataFlowEmitterExceptionHandler	exceptionHandler
protected net.sf.cglib.reflect.FastMethod	fastMethod
protected int	operatorNum
protected SignalHandler	signalHandler
protected DataFlowSignalManager	signalManager
protected java.lang.Object	targetObject

Constructor Summary

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

Method Summary

net.sf.cglib.reflect.FastMethod	getFastMethod()
void	handleSignal(EPDataFlowSignal signal)
void	submit(java.lang.Object object)
abstract void	submitInternal(java.lang.Object object)
void	submitPort(int portNumber, java.lang.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 java.lang.Object targetObject

Constructor Detail

EPDataFlowEmitter1Stream1TargetBase

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

Method Detail

submitInternal

public abstract void submitInternal(java.lang.Object object)

Specified by:

submitInternal in interface SubmitHandler

submit

public void submit(java.lang.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,
                       java.lang.Object object)

Specified by:

submitPort in interface EPDataFlowEmitter

getFastMethod

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

Specified by:

getFastMethod in interface SubmitHandler