Class OutputConditionExpressionForge
java.lang.Object
com.espertech.esper.common.internal.epl.output.condition.OutputConditionExpressionForge
- All Implemented Interfaces:
OutputConditionFactoryForge
,ScheduleHandleCallbackProvider
public class OutputConditionExpressionForge
extends Object
implements OutputConditionFactoryForge, ScheduleHandleCallbackProvider
Output condition for output rate limiting that handles when-then expressions for controlling output.
-
Field Summary
-
Constructor Summary
ConstructorDescriptionOutputConditionExpressionForge
(ExprNode whenExpressionNode, List<OnTriggerSetAssignment> assignments, ExprNode andWhenTerminatedExpr, List<OnTriggerSetAssignment> afterTerminateAssignments, boolean isStartConditionOnCreation, StateMgmtSetting stateMgmtSetting, StatementRawInfo statementRawInfo, StatementCompileTimeServices services) -
Method Summary
Modifier and TypeMethodDescriptionvoid
collectSchedules
(CallbackAttributionOutputRate callbackAttribution, List<ScheduleHandleTracked> scheduleHandleCallbackProviders) int
make
(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope) void
setScheduleCallbackId
(int id)
-
Field Details
-
isStartConditionOnCreation
protected final boolean isStartConditionOnCreation
-
-
Constructor Details
-
OutputConditionExpressionForge
public OutputConditionExpressionForge(ExprNode whenExpressionNode, List<OnTriggerSetAssignment> assignments, ExprNode andWhenTerminatedExpr, List<OnTriggerSetAssignment> afterTerminateAssignments, boolean isStartConditionOnCreation, StateMgmtSetting stateMgmtSetting, StatementRawInfo statementRawInfo, StatementCompileTimeServices services) throws ExprValidationException - Throws:
ExprValidationException
-
-
Method Details
-
make
public CodegenExpression make(CodegenMethodScope parent, SAIFFInitializeSymbol symbols, CodegenClassScope classScope) - Specified by:
make
in interfaceOutputConditionFactoryForge
-
collectSchedules
public void collectSchedules(CallbackAttributionOutputRate callbackAttribution, List<ScheduleHandleTracked> scheduleHandleCallbackProviders) - Specified by:
collectSchedules
in interfaceOutputConditionFactoryForge
-
setScheduleCallbackId
public void setScheduleCallbackId(int id) - Specified by:
setScheduleCallbackId
in interfaceScheduleHandleCallbackProvider
-
getScheduleCallbackId
public int getScheduleCallbackId()- Specified by:
getScheduleCallbackId
in interfaceScheduleHandleCallbackProvider
-