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

Interface AggregationMultiFunctionAccessor

public interface AggregationMultiFunctionAccessor
Accessor for access aggregation functions.

  • Field Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.

  • Method Details

    • getValue

      Object getValue(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
      Return the aggregation state value either as a scalar value or any other object.

      For enumeration over scalar values or objects return an array or collection of scalar or object values.

      Use the #getEnumerableEvents method to return a collection of events.

      Use the #getEnumerableEvent to return a single events.

      Parameters:
      state - aggregation state, downcast as needed
      eventsPerStream - events
      isNewData - new-data indicator
      exprEvaluatorContext - eval context
      Returns:
      return value

    • getEnumerableEvents

      default Collection<EventBean> getEnumerableEvents(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
      Return the aggregation state value consisting of a collection of events.
      Parameters:
      state - aggregation state, downcast as needed
      eventsPerStream - events
      isNewData - new-data indicator
      exprEvaluatorContext - eval context
      Returns:
      return collection of events or null or empty collection

    • getEnumerableEvent

      default EventBean getEnumerableEvent(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
      Return the aggregation state value consisting of a single event.
      Parameters:
      state - aggregation state, downcast as needed
      eventsPerStream - events
      isNewData - new-data indicator
      exprEvaluatorContext - eval context
      Returns:
      return event or null

    • getEnumerableScalar

      default Collection<Object> getEnumerableScalar(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
      Return the aggregation state value consisting of a collection of scalar values.
      Parameters:
      state - aggregation state, downcast as needed
      eventsPerStream - events
      isNewData - new-data indicator
      exprEvaluatorContext - eval context
      Returns:
      return collection of scalar or null or empty collection