Interface AggregationMultiFunctionAggregationMethod

All Known Implementing Classes:
AggregationMethodCountMinSketchFreq, AggregationMethodCountMinSketchTopK, AggregationMethodLinearCount, AggregationMethodLinearFirstLast, AggregationMethodLinearFirstLastIndex, AggregationMethodLinearListReference, AggregationMethodLinearWindow, AggregationMethodSortedEventsBetweenEval, AggregationMethodSortedKeyedEval, AggregationMethodSortedMinMaxBy, AggregationMethodSortedNoParamEval, AggregationMethodSortedSubmapEval, AggregationMethodSortedWindow

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 Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.
  • Method Details

    • getValue

      Object getValue(int aggColNum, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, 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, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, 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, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, 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, AggregationRow row, EventBean[] eventsPerStream, boolean isNewData, 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