Interface AggregationMultiFunctionState
public interface AggregationMultiFunctionState
Base interface for providing access-aggregations, i.e. aggregations that mirror a data window
but group by the group-by clause and that do not mirror the data windows sorting policy.
-
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
applyEnter
(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Enter an event.void
applyLeave
(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Remove an event.void
clear()
Clear all events in the group.
-
Field Details
-
EPTYPE
Type information.
-
-
Method Details
-
applyEnter
void applyEnter(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Enter an event.- Parameters:
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to addexprEvaluatorContext
- expression eval context
-
applyLeave
void applyLeave(EventBean[] eventsPerStream, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext) Remove an event.- Parameters:
eventsPerStream
- all events in all streams, typically implementations pick the relevant stream's events to removeexprEvaluatorContext
- expression eval context
-
clear
void clear()Clear all events in the group.
-