Package com.espertech.esper.common.internal.epl.dataflow.realize

Class EPDataFlowEmitter1Stream1TargetBase

java.lang.Object

com.espertech.esper.common.internal.epl.dataflow.realize.EPDataFlowEmitter1Stream1TargetBase

All Implemented Interfaces:

EPDataFlowEmitter, SubmitHandler

Direct Known Subclasses:

EPDataFlowEmitter1Stream1TargetPassAlong, EPDataFlowEmitter1Stream1TargetUnwind

public abstract class EPDataFlowEmitter1Stream1TargetBase
extends Object
implements EPDataFlowEmitter, SubmitHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected final EPDataFlowEmitterExceptionHandler	exceptionHandler
protected final Method	fastMethod
protected final int	operatorNum
protected final SignalHandler	signalHandler
protected final DataFlowSignalManager	signalManager
protected final Object	targetObject

Constructor Summary

Constructors

Constructor	Description
EPDataFlowEmitter1Stream1TargetBase(int operatorNum, DataFlowSignalManager signalManager, SignalHandler signalHandler, EPDataFlowEmitterExceptionHandler exceptionHandler, ObjectBindingPair target, ClasspathImportService classpathImportService)

Method Summary

Modifier and Type	Method	Description
Method	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 Details

operatorNum

protected final int operatorNum

signalManager

protected final DataFlowSignalManager signalManager

signalHandler

protected final SignalHandler signalHandler

exceptionHandler

protected final EPDataFlowEmitterExceptionHandler exceptionHandler

fastMethod

protected final Method fastMethod

targetObject

protected final Object targetObject

Constructor Details

EPDataFlowEmitter1Stream1TargetBase

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

Method Details

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 Method getFastMethod()

Specified by:

getFastMethod in interface SubmitHandler