Package 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 Details

    • EPTYPE

      public static final EPTypeClass EPTYPE

    • scheduleCallbackId

      protected int scheduleCallbackId

    • stateMgmtSetting

      protected StateMgmtSetting stateMgmtSetting

  • Constructor Details

    • OutputConditionExpressionFactory

      public OutputConditionExpressionFactory()

  • Method Details

    • 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)