Interface AggregationMultiFunctionAgent
- All Known Implementing Classes:
AggregationAgentCountMinSketch
,AggregationAgentDefault
,AggregationAgentDefaultWFilter
,AggregationAgentRewriteStream
,AggregationAgentRewriteStreamWFilter
public interface AggregationMultiFunctionAgent
Agents change mult-function aggregation state.
-
Field 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 aggregation
-
Field Details
-
EPTYPE
Type information.
-
-
Method Details
-
applyEnter
void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Enter-into (add to) an aggregation- Parameters:
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation state
-
applyLeave
void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Leave-from (remove from) an aggregation- Parameters:
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation state
-