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

Interface AggregationMultiFunctionAccessor

public interface AggregationMultiFunctionAccessor
Accessor for access aggregation functions.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final EPTypeClass
    EPTYPE
    Type information.

  • Method Summary

    Modifier and Type
    Method
    Description
    default EventBean
    getEnumerableEvent(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return the aggregation state value consisting of a single event.
    default Collection<EventBean>
    getEnumerableEvents(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return the aggregation state value consisting of a collection of events.
    default Collection<Object>
    getEnumerableScalar(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return the aggregation state value consisting of a collection of scalar values.
    Object
    getValue(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.ExprEvaluatorContext exprEvaluatorContext)
    Return the aggregation state value either as a scalar value or any other object.

  • Field Details

    • EPTYPE

      static final EPTypeClass EPTYPE
      Type information.

  • Method Details

    • getValue

      Object getValue(AggregationMultiFunctionState state, EventBean[] eventsPerStream, boolean isNewData, com.espertech.esper.common.internal.epl.expression.core.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, com.espertech.esper.common.internal.epl.expression.core.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, com.espertech.esper.common.internal.epl.expression.core.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, com.espertech.esper.common.internal.epl.expression.core.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