Interface AggregationMultiFunctionAgent

All Known Implementing Classes:
AggregationAgentCountMinSketch, AggregationAgentDefault, AggregationAgentDefaultWFilter, AggregationAgentRewriteStream, AggregationAgentRewriteStreamWFilter

public interface AggregationMultiFunctionAgent
Agents change mult-function aggregation state.
  • Field Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.
  • Method Details

    • applyEnter

      void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column)
      Enter-into (add to) an aggregation
      Parameters:
      eventsPerStream - events
      exprEvaluatorContext - evaluation context
      row - aggregation row
      column - column assigned to the aggregation state
    • applyLeave

      void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column)
      Leave-from (remove from) an aggregation
      Parameters:
      eventsPerStream - events
      exprEvaluatorContext - evaluation context
      row - aggregation row
      column - column assigned to the aggregation state