Class OutputConditionExpression
java.lang.Object
com.espertech.esper.common.internal.epl.output.condition.OutputConditionBase
com.espertech.esper.common.internal.epl.output.condition.OutputConditionExpression
- All Implemented Interfaces:
OutputCondition
,VariableChangeCallback
public class OutputConditionExpression
extends OutputConditionBase
implements OutputCondition, VariableChangeCallback
Output condition for output rate limiting that handles when-then expressions for controlling output.
-
Field Summary
Fields inherited from class com.espertech.esper.common.internal.epl.output.condition.OutputConditionBase
outputCallback
Fields inherited from interface com.espertech.esper.common.internal.epl.output.condition.OutputCondition
EPTYPE
-
Constructor Summary
ConstructorDescriptionOutputConditionExpression
(OutputCallback outputCallback, AgentInstanceContext agentInstanceContext, OutputConditionExpressionFactory parent) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
Indicate a change in variable value.void
updateOutputCondition
(int newEventsCount, int oldEventsCount) Update the output condition.
-
Field Details
-
NAME_AUDITPROVIDER_SCHEDULE
- See Also:
-
-
Constructor Details
-
OutputConditionExpression
public OutputConditionExpression(OutputCallback outputCallback, AgentInstanceContext agentInstanceContext, OutputConditionExpressionFactory parent)
-
-
Method Details
-
updateOutputCondition
public void updateOutputCondition(int newEventsCount, int oldEventsCount) Description copied from interface:OutputCondition
Update the output condition.- Specified by:
updateOutputCondition
in interfaceOutputCondition
- Parameters:
newEventsCount
- - number of new events incomingoldEventsCount
- - number of old events incoming
-
update
Description copied from interface:VariableChangeCallback
Indicate a change in variable value.- Specified by:
update
in interfaceVariableChangeCallback
- Parameters:
newValue
- new valueoldValue
- old value
-
stopOutputCondition
public void stopOutputCondition()- Specified by:
stopOutputCondition
in interfaceOutputCondition
-
terminated
public void terminated()- Specified by:
terminated
in interfaceOutputCondition
- Overrides:
terminated
in classOutputConditionBase
-