Interface AggregationMultiFunctionAggregationMethod


public interface AggregationMultiFunctionAggregationMethod
Aggregation method that operates on aggregation multi-function state such as provided by a multi-function aggregation (standalone or table column).
  • Field Summary

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

    Modifier and Type
    Method
    Description
    getValue(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Returns the plain value
    default Collection
    getValueCollectionEvents(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return a collection of events or null when not available.
    default Collection
    getValueCollectionScalar(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return a collection of values or null when not available.
    default EventBean
    getValueEventBean(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Returns a single event or null when not available.
  • Field Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.
  • Method Details

    • getValue

      Object getValue(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
      Returns the plain value
      Parameters:
      aggColNum - column number
      row - aggregation row
      eventsPerStream - events
      isNewData - new-data flag
      exprEvaluatorContext - evaluation context
      Returns:
      value
    • getValueCollectionEvents

      default Collection getValueCollectionEvents(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
      Return a collection of events or null when not available. The EPChainableType returned by the handler indicates whether the compiler allows operations on events.
      Parameters:
      aggColNum - column number
      row - aggregation row
      eventsPerStream - events
      isNewData - new-data flag
      exprEvaluatorContext - evaluation context
      Returns:
      collection of EventBean
    • getValueCollectionScalar

      default Collection getValueCollectionScalar(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
      Return a collection of values or null when not available. The EPChainableType returned by the handler indicates whether the compiler allows operations on events.
      Parameters:
      aggColNum - column number
      row - aggregation row
      eventsPerStream - events
      isNewData - new-data flag
      exprEvaluatorContext - evaluation context
      Returns:
      collection of values
    • getValueEventBean

      default EventBean getValueEventBean(int aggColNum, com.espertech.esper.common.internal.epl.agg.core.AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
      Returns a single event or null when not available. The EPChainableType returned by the handler indicates whether the compiler allows operations on events.
      Parameters:
      aggColNum - column number
      row - aggregation row
      eventsPerStream - events
      isNewData - new-data flag
      exprEvaluatorContext - evaluation context
      Returns:
      event