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

    Fields
    Modifier and Type
    Field
    Description
    static final EPTypeClass
    Type information.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    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 all events in the group.
  • Field Details

    • EPTYPE

      static final EPTypeClass 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 add
      exprEvaluatorContext - 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 remove
      exprEvaluatorContext - expression eval context
    • clear

      void clear()
      Clear all events in the group.