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

All Known Implementing Classes:

ExprAggCountMinSketchNodeFactoryBase, ExprAggCountMinSketchNodeFactoryState, ExprAggCountMinSketchNodeFactoryUse, ExprAggMultiFunctionLinearAccessNodeFactoryAccess, ExprAggMultiFunctionLinearAccessNodeFactoryMethod, ExprAggMultiFunctionSortedMinMaxByNodeFactory, ExprAvedevNodeFactory, ExprAvgNodeFactory, ExprCountEverNodeFactory, ExprCountNodeFactory, ExprFirstEverNodeFactory, ExprLastEverNodeFactory, ExprLeavingAggNodeFactory, ExprMedianNodeFactory, ExprMinMaxAggrNodeFactory, ExprNthAggNodeFactory, ExprPlugInAggFunctionFactory, ExprPlugInAggMultiFunctionNodeFactory, ExprRateAggNodeFactory, ExprStddevNodeFactory, ExprSumNodeFactory

public interface AggregationMethodFactory

Factory for aggregation methods.

Method Summary

AggregationAccessor	getAccessor()
ExprAggregateNodeBase	getAggregationExpression()
AggregationAgent	getAggregationStateAgent()
AggregationStateFactory	getAggregationStateFactory(boolean isMatchRecognize)
AggregationStateKey	getAggregationStateKey(boolean isMatchRecognize)
ExprEvaluator	getMethodAggregationEvaluator(boolean join, EventType[] typesPerStream)
java.lang.Class	getResultType()
boolean	isAccessAggregation()
AggregationMethod	make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
void	validateIntoTableCompatible(AggregationMethodFactory intoTableAgg)

Method Detail

isAccessAggregation

boolean isAccessAggregation()

make

AggregationMethod make(MethodResolutionService methodResolutionService,
                       int agentInstanceId,
                       int groupId,
                       int aggregationId)

getResultType

java.lang.Class getResultType()

getAggregationStateKey

AggregationStateKey getAggregationStateKey(boolean isMatchRecognize)

getAggregationStateFactory

AggregationStateFactory getAggregationStateFactory(boolean isMatchRecognize)

getAccessor

AggregationAccessor getAccessor()

getAggregationExpression

ExprAggregateNodeBase getAggregationExpression()

validateIntoTableCompatible

void validateIntoTableCompatible(AggregationMethodFactory intoTableAgg)
                                 throws ExprValidationException

Throws:

ExprValidationException

getAggregationStateAgent

AggregationAgent getAggregationStateAgent()

getMethodAggregationEvaluator

ExprEvaluator getMethodAggregationEvaluator(boolean join,
                                            EventType[] typesPerStream)
                                            throws ExprValidationException

Throws:

ExprValidationException