com.espertech.esper.epl.agg.service
Interface AggregationResultFuture

All Known Subinterfaces:

AggregationService, AggregationServiceMatchRecognize, AIRegistryAggregation

All Known Implementing Classes:

AggregationServiceBase, AggregationServiceBaseGrouped, AggregationServiceBaseUngrouped, AggregationServiceMatchRecognizeImpl, AggregationServiceNull, AggregationServiceTable, AggSvcGroupAllAccessOnlyImpl, AggSvcGroupAllLocalGroupBy, AggSvcGroupAllMixedAccessImpl, AggSvcGroupAllMixedAccessWTableImpl, AggSvcGroupAllNoAccessImpl, AggSvcGroupByAccessOnlyImpl, AggSvcGroupByLocalGroupBy, AggSvcGroupByMixedAccessImpl, AggSvcGroupByNoAccessImpl, AggSvcGroupByReclaimAgedImpl, AggSvcGroupByRefcountedNoAccessImpl, AggSvcGroupByRefcountedWAccessImpl, AggSvcGroupByRefcountedWAccessRollupImpl, AggSvcGroupByWTableBase, AggSvcGroupByWTableImpl, AggSvcGroupByWTableRollupMultiKeyImpl, AggSvcGroupByWTableRollupSingleKeyImpl, AggSvcGroupLocalGroupByBase, AIRegistryAggregationMap, AIRegistryAggregationMultiPerm, AIRegistryAggregationSingle

public interface AggregationResultFuture

Interface for use by aggregate expression nodes representing aggregate functions such as 'sum' or 'avg' to use to obtain the current value for the function at time of expression evaluation.

Method Summary

java.util.Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.util.Collection<java.lang.Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Object	getGroupKey(int agentInstanceId)
java.util.Collection<java.lang.Object>	getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	getValue(int column, int agentInstanceId, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns current aggregation state, for use by expression node representing an aggregation function.

Method Detail

getValue

java.lang.Object getValue(int column,
                          int agentInstanceId,
                          EventBean[] eventsPerStream,
                          boolean isNewData,
                          ExprEvaluatorContext exprEvaluatorContext)

Returns current aggregation state, for use by expression node representing an aggregation function.

Parameters:

column - is assigned to the aggregation expression node and passed as an column (index) into a row

agentInstanceId - the context partition id

eventsPerStream -

isNewData -

exprEvaluatorContext -

Returns:

current aggragation state

getCollectionOfEvents

java.util.Collection<EventBean> getCollectionOfEvents(int column,
                                                      EventBean[] eventsPerStream,
                                                      boolean isNewData,
                                                      ExprEvaluatorContext context)

getEventBean

EventBean getEventBean(int column,
                       EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext context)

getGroupKey

java.lang.Object getGroupKey(int agentInstanceId)

getGroupKeys

java.util.Collection<java.lang.Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)

getCollectionScalar

java.util.Collection<java.lang.Object> getCollectionScalar(int column,
                                                           EventBean[] eventsPerStream,
                                                           boolean isNewData,
                                                           ExprEvaluatorContext context)