Package 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.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Method Summary

Modifier and Type	Method	Description
AggregationRow	getAggregationRow(int agentInstanceId, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
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.

Field Details

EPTYPE

static final EPTypeClass EPTYPE

Method Details

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)

getAggregationRow

AggregationRow getAggregationRow(int agentInstanceId,
 EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext exprEvaluatorContext)

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