public interface AggregationMultiFunctionAgent
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
int column)
Enter-into (add to) an aggregation
|
void |
applyLeave(EventBean[] eventsPerStream,
com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext,
com.espertech.esper.common.internal.epl.agg.core.AggregationRow row,
int column)
Leave-from (remove from) an aggregation
|
void applyEnter(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, int column)
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation statevoid applyLeave(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, int column)
eventsPerStream
- eventsexprEvaluatorContext
- evaluation contextrow
- aggregation rowcolumn
- column assigned to the aggregation state