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

Modifier and Type	Method and Description
Collection<EventBean>	getCollectionOfEvents(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<Object>	getCollectionScalar(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
EventBean	getEventBean(int column, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	getGroupKey(int agentInstanceId)
Collection<Object>	getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
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

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 - events per stream

isNewData - new vs removed indicator

exprEvaluatorContext - context

Returns:

current aggragation state

getCollectionOfEvents

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

getEventBean

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

getGroupKey

Object getGroupKey(int agentInstanceId)

getGroupKeys

Collection<Object> getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)

getCollectionScalar

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