com.espertech.esper.epl.agg.service

Interface AggregationMethodFactory

All Known Implementing Classes:

AggregationMethodFactoryAvedev, AggregationMethodFactoryAvg, AggregationMethodFactoryCount, AggregationMethodFactoryCountEver, AggregationMethodFactoryFirstEver, AggregationMethodFactoryFirstLastUnbound, AggregationMethodFactoryLastEver, AggregationMethodFactoryLeaving, AggregationMethodFactoryMedian, AggregationMethodFactoryMinMax, AggregationMethodFactoryNth, AggregationMethodFactoryPlugIn, AggregationMethodFactoryRate, AggregationMethodFactoryStddev, AggregationMethodFactorySum, ExprAggCountMinSketchNodeFactoryBase, ExprAggCountMinSketchNodeFactoryState, ExprAggCountMinSketchNodeFactoryUse, ExprAggMultiFunctionLinearAccessNodeFactoryAccess, ExprAggMultiFunctionSortedMinMaxByNodeFactory, ExprPlugInAggMultiFunctionNodeFactory

public interface AggregationMethodFactory

Factory for aggregation methods.

Method Summary

Modifier and Type	Method and Description
AggregationAccessor	getAccessor()
ExprAggregateNodeBase	getAggregationExpression()
AggregationAgent	getAggregationStateAgent(EngineImportService engineImportService, String statementName)
AggregationStateFactory	getAggregationStateFactory(boolean isMatchRecognize)
AggregationStateKey	getAggregationStateKey(boolean isMatchRecognize)
ExprEvaluator	getMethodAggregationEvaluator(boolean join, EventType[] typesPerStream)
Class	getResultType()
boolean	isAccessAggregation()
AggregationMethod	make()
void	validateIntoTableCompatible(AggregationMethodFactory intoTableAgg)

Method Detail

isAccessAggregation

boolean isAccessAggregation()

make

AggregationMethod make()

getResultType

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(EngineImportService engineImportService,
                                          String statementName)

getMethodAggregationEvaluator

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

Throws:

ExprValidationException