com.espertech.esper.common.internal.epl.output.condition

Class OutputConditionExpressionFactory

java.lang.Object

com.espertech.esper.common.internal.epl.output.condition.OutputConditionExpressionFactory

All Implemented Interfaces:

StatementReadyCallback, OutputConditionFactory

public class OutputConditionExpressionFactory
extends Object
implements OutputConditionFactory, StatementReadyCallback

Output condition for output rate limiting that handles when-then expressions for controlling output.

Field Summary

Fields

Modifier and Type	Field and Description
static EPTypeClass	EPTYPE
protected int	scheduleCallbackId
protected StateMgmtSetting	stateMgmtSetting

Constructor Summary

Constructors

Constructor and Description
OutputConditionExpressionFactory()

Method Summary

Modifier and Type	Method and Description
ExprEvaluator	getAndWhenTerminatedExpressionNodeEval()
EventType	getBuiltinPropertiesEventType()
int	getScheduleCallbackId()
StateMgmtSetting	getStateMgmtSetting()
VariableReadWritePackage	getVariableReadWritePackage()
VariableReadWritePackage	getVariableReadWritePackageAfterTerminated()
Variable[]	getVariables()
ExprEvaluator	getWhenExpressionNodeEval()
OutputCondition	instantiateOutputCondition(AgentInstanceContext agentInstanceContext, OutputCallback outputCallback)
boolean	isStartConditionOnCreation()
void	ready(StatementContext statementContext, ModuleIncidentals moduleIncidentals, boolean recovery)
void	setAndWhenTerminatedExpressionNodeEval(ExprEvaluator andWhenTerminatedExpressionNodeEval)
void	setScheduleCallbackId(int scheduleCallbackId)
void	setStartConditionOnCreation(boolean startConditionOnCreation)
void	setStateMgmtSetting(StateMgmtSetting stateMgmtSetting)
void	setUsingBuiltinProperties(boolean usingBuiltinProperties)
void	setVariableReadWritePackage(VariableReadWritePackage variableReadWritePackage)
void	setVariableReadWritePackageAfterTerminated(VariableReadWritePackage variableReadWritePackageAfterTerminated)
void	setVariables(Variable[] variables)
void	setWhenExpressionNodeEval(ExprEvaluator whenExpressionNodeEval)

Methods inherited from class java.lang.Object

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

Field Detail

EPTYPE

public static final EPTypeClass EPTYPE

scheduleCallbackId

protected int scheduleCallbackId

stateMgmtSetting

protected StateMgmtSetting stateMgmtSetting

Constructor Detail

OutputConditionExpressionFactory

public OutputConditionExpressionFactory()

Method Detail

setWhenExpressionNodeEval

public void setWhenExpressionNodeEval(ExprEvaluator whenExpressionNodeEval)

setAndWhenTerminatedExpressionNodeEval

public void setAndWhenTerminatedExpressionNodeEval(ExprEvaluator andWhenTerminatedExpressionNodeEval)

setStartConditionOnCreation

public void setStartConditionOnCreation(boolean startConditionOnCreation)

setUsingBuiltinProperties

public void setUsingBuiltinProperties(boolean usingBuiltinProperties)

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

getWhenExpressionNodeEval

public ExprEvaluator getWhenExpressionNodeEval()

getAndWhenTerminatedExpressionNodeEval

public ExprEvaluator getAndWhenTerminatedExpressionNodeEval()

isStartConditionOnCreation

public boolean isStartConditionOnCreation()

getBuiltinPropertiesEventType

public EventType getBuiltinPropertiesEventType()

getVariableReadWritePackage

public VariableReadWritePackage getVariableReadWritePackage()

getVariableReadWritePackageAfterTerminated

public VariableReadWritePackage getVariableReadWritePackageAfterTerminated()

setVariableReadWritePackage

public void setVariableReadWritePackage(VariableReadWritePackage variableReadWritePackage)

setVariableReadWritePackageAfterTerminated

public void setVariableReadWritePackageAfterTerminated(VariableReadWritePackage variableReadWritePackageAfterTerminated)

getVariables

public Variable[] getVariables()

setVariables

public void setVariables(Variable[] variables)

ready

public void ready(StatementContext statementContext,
                  ModuleIncidentals moduleIncidentals,
                  boolean recovery)

Specified by:

ready in interface StatementReadyCallback

instantiateOutputCondition

public OutputCondition instantiateOutputCondition(AgentInstanceContext agentInstanceContext,
                                                  OutputCallback outputCallback)

Specified by:

instantiateOutputCondition in interface OutputConditionFactory

getScheduleCallbackId

public int getScheduleCallbackId()

getStateMgmtSetting

public StateMgmtSetting getStateMgmtSetting()

setStateMgmtSetting

public void setStateMgmtSetting(StateMgmtSetting stateMgmtSetting)