Uses of Interface
com.espertech.esper.epl.agg.aggregator.AggregationMethod

Packages that use AggregationMethod

com.espertech.esper.client.hook	Callback interfaces for use with statement annotations.
com.espertech.esper.epl.agg.aggregator	Aggregation function implementations.
com.espertech.esper.epl.agg.service	Aggregation services.
com.espertech.esper.epl.core	Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc.
com.espertech.esper.epl.expression.accessagg	Access-aggregation expressions.
com.espertech.esper.epl.expression.methodagg	Method-aggregation expressions.
com.espertech.esper.metrics.instrumentation	EPL instrumentation helpers.

Uses of AggregationMethod in com.espertech.esper.client.hook

Methods in com.espertech.esper.client.hook that return AggregationMethod

AggregationMethod

AggregationFunctionFactory.newAggregator() Make a new, initalized aggregation state.

Uses of AggregationMethod in com.espertech.esper.epl.agg.aggregator

Classes in com.espertech.esper.epl.agg.aggregator that implement AggregationMethod

class	AggregatorAvedev Standard deviation always generates double-types numbers.
class	AggregatorAvedevFilter Standard deviation always generates double-types numbers.
class	AggregatorAvg Average that generates double-typed numbers.
class	AggregatorAvgBigDecimal Average that generates a BigDecimal numbers.
class	AggregatorAvgBigDecimalFilter Average that generates a BigDecimal numbers.
class	AggregatorAvgFilter Average that generates double-typed numbers.
class	AggregatorCount Counts all datapoints including null values.
class	AggregatorCountEver Aggregator for count-ever value.
class	AggregatorCountEverFilter Aggregator for the count-ever value.
class	AggregatorCountEverNonNull Aggregator for count-ever value.
class	AggregatorCountEverNonNullFilter Aggregator for the count-ever value.
class	AggregatorCountFilter Counts all datapoints including null values.
class	AggregatorCountNonNull Count all non-null values.
class	AggregatorCountNonNullFilter Count all non-null values.
class	AggregatorDistinctValue AggregationMethod for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation) for the underlying aggregator.
class	AggregatorDistinctValueFilter AggregationMethod for use on top of another aggregator that handles unique value aggregation (versus all-value aggregation) for the underlying aggregator.
class	AggregatorFirstEver Aggregator for the very first value.
class	AggregatorFirstEverFilter Aggregator for the very first value.
class	AggregatorLastEver Aggregator for the very last value.
class	AggregatorLastEverFilter Aggregator for the very last value.
class	AggregatorLeaving For testing if a remove stream entry has been present.
class	AggregatorMedian Median aggregation.
class	AggregatorMedianFilter Median aggregation.
class	AggregatorMinMax Min/max aggregator for all values.
class	AggregatorMinMaxEver Min/max aggregator for all values, not considering events leaving the aggregation (i.e.
class	AggregatorMinMaxEverFilter Min/max aggregator for all values, not considering events leaving the aggregation (i.e.
class	AggregatorMinMaxFilter Min/max aggregator for all values.
class	AggregatorNth Aggregator to return the Nth oldest element to enter, with N=1 the most recent value is returned.
class	AggregatorRate Aggregation computing an event arrival rate for data windowed-events.
class	AggregatorRateEver Aggregation computing an event arrival rate for with and without data window.
class	AggregatorStddev Standard deviation always generates double-typed numbers.
class	AggregatorStddevFilter Standard deviation always generates double-typed numbers.
class	AggregatorSumBigDecimal Sum for BigInteger values.
class	AggregatorSumBigDecimalFilter Sum for BigInteger values.
class	AggregatorSumBigInteger Sum for BigInteger values.
class	AggregatorSumBigIntegerFilter Sum for BigInteger values.
class	AggregatorSumDouble Sum for double values.
class	AggregatorSumDoubleFilter Sum for double values.
class	AggregatorSumFloat Sum for float values.
class	AggregatorSumFloatFilter Sum for float values.
class	AggregatorSumInteger Sum for integer values.
class	AggregatorSumIntegerFilter Sum for integer values.
class	AggregatorSumLong Sum for long values.
class	AggregatorSumLongFilter Sum for long values.
class	AggregatorSumNumInteger Sum for any number value.
class	AggregatorSumNumIntegerFilter Sum for any number value.

Fields in com.espertech.esper.epl.agg.aggregator declared as AggregationMethod

protected AggregationMethod	AggregatorDistinctValueFilter.inner
protected AggregationMethod	AggregatorDistinctValue.inner

Constructors in com.espertech.esper.epl.agg.aggregator with parameters of type AggregationMethod

AggregatorDistinctValue(AggregationMethod inner)
Ctor.

AggregatorDistinctValueFilter(AggregationMethod inner)
Ctor.

Uses of AggregationMethod in com.espertech.esper.epl.agg.service

Fields in com.espertech.esper.epl.agg.service declared as AggregationMethod

protected AggregationMethod[]	AggregationServiceBaseUngrouped.aggregators Aggregation states.
protected AggregationMethod[]	AggSvcGroupLocalGroupByBase.aggregatorsTopLevel
protected AggregationMethod[]	AggSvcGroupByWTableBase.currentAggregatorMethods

Methods in com.espertech.esper.epl.agg.service that return AggregationMethod

AggregationMethod[]	AggSvcGroupLocalGroupByBase.getAggregatorsTopLevel()
AggregationMethod[]	AggregationRowPair.getMethods() Returns aggregation methods.
AggregationMethod[]	AggregationMethodRowAged.getMethods() Returns aggregation state.
AggregationMethod[]	AggregationMethodRow.getMethods() Returns aggregation state.
AggregationMethod[]	AggregationMethodPairRow.getMethods() Returns aggregation state.
AggregationMethod	AggregationMethodFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)

Methods in com.espertech.esper.epl.agg.service with parameters of type AggregationMethod

protected static void	AggSvcGroupLocalGroupByBase.aggregateIntoEnter(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
protected static void	AggSvcGroupLocalGroupByBase.aggregateIntoLeave(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
protected static void	AggSvcGroupLocalGroupByBase.clearResults(java.util.Map<java.lang.Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup, AggregationMethod[] aggregatorsTopLevel, AggregationState[] statesTopLevel)
void	AggSvcGroupLocalGroupByBase.setAggregatorsTopLevel(AggregationMethod[] aggregatorsTopLevel)

Constructors in com.espertech.esper.epl.agg.service with parameters of type AggregationMethod

AggregationMethodPairRow(long refcount, AggregationMethod[] methods, AggregationState[] states)
Ctor.

AggregationMethodRow(long refcount, AggregationMethod[] methods)
Ctor.

AggregationMethodRowAged(long refcount, long lastUpdateTime, AggregationMethod[] methods, AggregationState[] states)
Ctor.

AggregationRowPair(AggregationMethod[] methods, AggregationState[] states)
Ctor.

AggregationServiceBaseUngrouped(ExprEvaluator[] evaluators, AggregationMethod[] aggregators, AggregationMethodFactory[] aggregatorFactories, AggregationStateFactory[] accessAggregations)
Ctor.

AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream, AggregationMethod[][] aggregatorsEachStream, AggregationMethod[] aggregatorsAll)

AggregationServiceMatchRecognizeImpl(ExprEvaluator[][] evaluatorsEachStream, AggregationMethod[][] aggregatorsEachStream, AggregationMethod[] aggregatorsAll)

AggSvcGroupAllMixedAccessImpl(ExprEvaluator[] evaluators, AggregationMethod[] aggregators, AggregationAccessorSlotPair[] accessors, AggregationState[] states, AggregationMethodFactory[] aggregatorFactories, AggregationStateFactory[] accessAggregations)

AggSvcGroupAllNoAccessImpl(ExprEvaluator[] evaluators, AggregationMethod[] aggregators, AggregationMethodFactory[] aggregatorFactories)
Ctor.

AggSvcGroupByRefcountedWAccessRollupImpl(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, java.lang.Object groupKeyBinding, MethodResolutionService methodResolutionService, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin, AggregationGroupByRollupDesc rollupLevelDesc, AggregationMethod[] topGroupAggregators, AggregationState[] topGroupStates)
Ctor.

Uses of AggregationMethod in com.espertech.esper.epl.core

Methods in com.espertech.esper.epl.core that return AggregationMethod

AggregationMethod	MethodResolutionServiceImpl.makeAvedevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeAvedevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new avedev-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeAvgAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeAvgAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new avg-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeCountAggregator(int agentInstanceId, int groupId, int aggregationId, boolean isIgnoreNull, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeCountAggregator(int agentInstanceId, int groupId, int aggregationId, boolean isIgnoreNull, boolean hasFilter) Makes a new count-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeCountEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter, boolean ignoreNulls)
AggregationMethod	MethodResolutionService.makeCountEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter, boolean ignoreNulls) Makes a new countever-value aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeDistinctAggregator(int agentInstanceId, int groupId, int aggregationId, AggregationMethod aggregationMethod, java.lang.Class childType, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeDistinctAggregator(int agentInstanceId, int groupId, int aggregationId, AggregationMethod aggregationMethod, java.lang.Class childType, boolean hasFilter) Makes a new distinct-value-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeFirstEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeFirstEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new first-value aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeLastEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeLastEverValueAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new last-value aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeLeavingAggregator(int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	MethodResolutionService.makeLeavingAggregator(int agentInstanceId, int groupId, int aggregationId) Make leaving agg.
AggregationMethod	MethodResolutionServiceImpl.makeMedianAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeMedianAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new median-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeMinMaxAggregator(int agentInstanceId, int groupId, int aggregationId, MinMaxTypeEnum minMaxTypeEnum, java.lang.Class targetType, boolean isHasDataWindows, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeMinMaxAggregator(int agentInstanceId, int groupId, int aggregationId, MinMaxTypeEnum minMaxType, java.lang.Class targetType, boolean isHasDataWindows, boolean hasFilter) Makes a new min-max-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeNthAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class returnType, int size)
AggregationMethod	MethodResolutionService.makeNthAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class returnType, int size) Makes a Nth element aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeRateAggregator(int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	MethodResolutionService.makeRateAggregator(int agentInstanceId, int groupId, int aggregationId) Makes a new rate-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeRateEverAggregator(int agentInstanceId, int groupId, int aggregationId, long interval)
AggregationMethod	MethodResolutionService.makeRateEverAggregator(int agentInstanceId, int groupId, int aggregationId, long interval) Makes a new rate-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeStddevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeStddevAggregator(int agentInstanceId, int groupId, int aggregationId, boolean hasFilter) Makes a new stddev-aggregator.
AggregationMethod	MethodResolutionServiceImpl.makeSumAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeSumAggregator(int agentInstanceId, int groupId, int aggregationId, java.lang.Class type, boolean hasFilter) Makes a new sum-aggregator.
AggregationMethod[]	MethodResolutionServiceImpl.newAggregators(AggregationMethodFactory[] prototypes, int agentInstanceId)
AggregationMethod[]	MethodResolutionService.newAggregators(AggregationMethodFactory[] aggregators, int agentInstanceId) Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition (no groups).
AggregationMethod[]	MethodResolutionServiceImpl.newAggregators(AggregationMethodFactory[] prototypes, int agentInstanceId, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel)
AggregationMethod[]	MethodResolutionService.newAggregators(AggregationMethodFactory[] prototypes, int agentInstanceId, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel) Returns a new set of aggregators given an existing prototype-set of aggregators for a given context partition and group key.
AggregationMethod[]	MethodResolutionServiceImpl.newAggregatorsInternal(AggregationMethodFactory[] prototypes, int agentInstanceId)

Methods in com.espertech.esper.epl.core with parameters of type AggregationMethod

long	MethodResolutionServiceImpl.getCurrentRowCount(AggregationMethod[] aggregators, AggregationState[] groupStates)
long	MethodResolutionService.getCurrentRowCount(AggregationMethod[] aggregators, AggregationState[] states) Returns the current row count of an aggregation, for use with resilience.
AggregationMethod	MethodResolutionServiceImpl.makeDistinctAggregator(int agentInstanceId, int groupId, int aggregationId, AggregationMethod aggregationMethod, java.lang.Class childType, boolean hasFilter)
AggregationMethod	MethodResolutionService.makeDistinctAggregator(int agentInstanceId, int groupId, int aggregationId, AggregationMethod aggregationMethod, java.lang.Class childType, boolean hasFilter) Makes a new distinct-value-aggregator.

Uses of AggregationMethod in com.espertech.esper.epl.expression.accessagg

Methods in com.espertech.esper.epl.expression.accessagg that return AggregationMethod

AggregationMethod	ExprPlugInAggMultiFunctionNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAggMultiFunctionSortedMinMaxByNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAggMultiFunctionLinearAccessNodeFactoryMethod.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAggMultiFunctionLinearAccessNodeFactoryAccess.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAggCountMinSketchNodeFactoryBase.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)

Uses of AggregationMethod in com.espertech.esper.epl.expression.methodagg

Methods in com.espertech.esper.epl.expression.methodagg that return AggregationMethod

AggregationMethod	ExprSumNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprStddevNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprRateAggNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprPlugInAggFunctionFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprNthAggNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprMinMaxAggrNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprMedianNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprLeavingAggNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprLastEverNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprFirstEverNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprCountNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprCountEverNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAvgNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)
AggregationMethod	ExprAvedevNodeFactory.make(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId)

Uses of AggregationMethod in com.espertech.esper.metrics.instrumentation

Methods in com.espertech.esper.metrics.instrumentation with parameters of type AggregationMethod

void	InstrumentationDefault.aAggNoAccessEnterLeave(boolean enter, int index, AggregationMethod aggregationMethod)
void	Instrumentation.aAggNoAccessEnterLeave(boolean enter, int index, AggregationMethod aggregationMethod)
void	InstrumentationDefault.qAggNoAccessEnterLeave(boolean enter, int index, AggregationMethod aggregationMethod, ExprNode aggExpr)
void	Instrumentation.qAggNoAccessEnterLeave(boolean enter, int index, AggregationMethod aggregationMethod, ExprNode aggExpr)