Class AggregationAgentCountMinSketch
java.lang.Object
com.espertech.esper.common.internal.epl.agg.access.countminsketch.AggregationAgentCountMinSketch
- All Implemented Interfaces:
AggregationMultiFunctionAgent
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
applyEnter
(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Enter-into (add to) an aggregationvoid
applyLeave
(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Leave-from (remove from) an aggregationvoid
setOptionalFilterEval
(ExprEvaluator optionalFilterEval) void
setStringEval
(ExprEvaluator stringEval)
-
Field Details
-
EPTYPE
-
-
Constructor Details
-
AggregationAgentCountMinSketch
public AggregationAgentCountMinSketch()
-
-
Method Details
-
setStringEval
-
setOptionalFilterEval
-
applyEnter
public void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Description copied from interface:AggregationMultiFunctionAgent
Enter-into (add to) an aggregation- Specified by:
applyEnter
in interfaceAggregationMultiFunctionAgent
- Parameters:
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation state
-
applyLeave
public void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Description copied from interface:AggregationMultiFunctionAgent
Leave-from (remove from) an aggregation- Specified by:
applyLeave
in interfaceAggregationMultiFunctionAgent
- Parameters:
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation state
-