Package com.espertech.esper.common.client.hook.aggmultifunc

Interface AggregationMultiFunctionState

All Known Implementing Classes:
CountMinSketchAggState
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 Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.

  • Method Details

    • 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.