com.espertech.esper.epl.agg.access

Interface AggregationState

All Known Subinterfaces:

AggregationStateWithSize

All Known Implementing Classes:

AggregationStateLinearImpl, AggregationStateLinearJoinImpl, AggregationStateLinearJoinWFilter, AggregationStateLinearWFilter, AggregationStateMinMaxByEver, AggregationStateMinMaxByEverWFilter, AggregationStateSortedImpl, AggregationStateSortedJoin, AggregationStateSortedJoinWFilter, AggregationStateSortedWFilter, CountMinSketchAggState

public interface AggregationState

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.

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Enter an event.
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Remove an event.
void	clear() Clear all events in the group.

Method Detail

applyEnter

void applyEnter(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

Enter an event.

Parameters:

eventsPerStream - all events in all streams, typically implementations pick the relevant stream's events to add

exprEvaluatorContext - expression eval context

applyLeave

void applyLeave(EventBean[] eventsPerStream,
                ExprEvaluatorContext exprEvaluatorContext)

Remove an event.

Parameters:

eventsPerStream - all events in all streams, typically implementations pick the relevant stream's events to remove

exprEvaluatorContext - expression eval context

clear

void clear()

Clear all events in the group.