com.espertech.esper.epl.agg.factory

Class AggregationMethodFactoryRate

java.lang.Object

com.espertech.esper.epl.agg.factory.AggregationMethodFactoryRate

All Implemented Interfaces:

AggregationMethodFactory

public class AggregationMethodFactoryRate
extends Object
implements AggregationMethodFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected long	intervalTime
protected boolean	isEver
protected ExprRateAggNode	parent
protected TimeAbacus	timeAbacus
protected TimeProvider	timeProvider

Constructor Summary

Constructors

Constructor and Description
AggregationMethodFactoryRate(ExprRateAggNode parent, boolean isEver, long intervalTime, TimeProvider timeProvider, TimeAbacus timeAbacus)

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

parent

protected final ExprRateAggNode parent

isEver

protected final boolean isEver

intervalTime

protected final long intervalTime

timeProvider

protected final TimeProvider timeProvider

timeAbacus

protected final TimeAbacus timeAbacus

Constructor Detail

AggregationMethodFactoryRate

public AggregationMethodFactoryRate(ExprRateAggNode parent,
                                    boolean isEver,
                                    long intervalTime,
                                    TimeProvider timeProvider,
                                    TimeAbacus timeAbacus)

Method Detail

isAccessAggregation

public boolean isAccessAggregation()

Specified by:

isAccessAggregation in interface AggregationMethodFactory

getResultType

public Class getResultType()

Specified by:

getResultType in interface AggregationMethodFactory

getAggregationStateKey

public AggregationStateKey getAggregationStateKey(boolean isMatchRecognize)

Specified by:

getAggregationStateKey in interface AggregationMethodFactory

getAggregationStateFactory

public AggregationStateFactory getAggregationStateFactory(boolean isMatchRecognize)

Specified by:

getAggregationStateFactory in interface AggregationMethodFactory

getAccessor

public AggregationAccessor getAccessor()

Specified by:

getAccessor in interface AggregationMethodFactory

make

public AggregationMethod make()

Specified by:

make in interface AggregationMethodFactory

getAggregationExpression

public ExprAggregateNodeBase getAggregationExpression()

Specified by:

getAggregationExpression in interface AggregationMethodFactory

validateIntoTableCompatible

public void validateIntoTableCompatible(AggregationMethodFactory intoTableAgg)
                                 throws ExprValidationException

Specified by:

validateIntoTableCompatible in interface AggregationMethodFactory

Throws:

ExprValidationException

getAggregationStateAgent

public AggregationAgent getAggregationStateAgent(EngineImportService engineImportService,
                                                 String statementName)

Specified by:

getAggregationStateAgent in interface AggregationMethodFactory

getMethodAggregationEvaluator

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

Specified by:

getMethodAggregationEvaluator in interface AggregationMethodFactory

Throws:

ExprValidationException