com.espertech.esper.common.internal.epl.agg.core

Interface AggregationResultFuture

All Known Subinterfaces:

AggregationService, AggregationServiceMatchRecognize, AIRegistryAggregation

All Known Implementing Classes:

AggregationServiceNull, AggSvcGroupAllWTableImpl, AggSvcGroupByWTableBase, AggSvcGroupByWTableImpl, AggSvcGroupByWTableRollupMultiKeyImpl, AggSvcGroupByWTableRollupSingleKeyImpl, 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)
AggregationService	getContextPartitionAggregationService(int agentInstanceId)
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)
void	setCurrentAccess(Object groupKey, int agentInstanceId, AggregationGroupByRollupLevel rollupLevel) Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.

Method Detail

getValue

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

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)

getContextPartitionAggregationService

AggregationService getContextPartitionAggregationService(int agentInstanceId)

setCurrentAccess

void setCurrentAccess(Object groupKey,
                      int agentInstanceId,
                      AggregationGroupByRollupLevel rollupLevel)

Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.

Parameters:

groupKey - - single key identifying the row of aggregation states

agentInstanceId - context partition id

rollupLevel - rollup level