Uses of Interface
com.espertech.esper.epl.agg.access.AggregationState

Packages that use AggregationState

Package	Description
com.espertech.esper.epl.agg.access	State multifunction aggregation methods
com.espertech.esper.epl.agg.factory	Aggregator factories
com.espertech.esper.epl.agg.service	Aggregation services.
com.espertech.esper.epl.approx	Approximation algos.
com.espertech.esper.metrics.instrumentation	EPL instrumentation helpers.
com.espertech.esper.plugin	APIs for plug-in adapter (for input-output) and plug-in event representation (event types and event objects) are in this package.

Uses of AggregationState in com.espertech.esper.epl.agg.access

Subinterfaces of AggregationState in com.espertech.esper.epl.agg.access

Modifier and Type	Interface and Description
interface	AggregationStateWithSize

Classes in com.espertech.esper.epl.agg.access that implement AggregationState

Modifier and Type	Class and Description
class	AggregationStateLinearImpl Implementation of access function for single-stream (not joins).
class	AggregationStateLinearJoinImpl Implementation of access function for joins.
class	AggregationStateLinearJoinWFilter Implementation of access function for joins.
class	AggregationStateLinearWFilter
class	AggregationStateMinMaxByEver Implementation of access function for single-stream (not joins).
class	AggregationStateMinMaxByEverWFilter
class	AggregationStateSortedImpl Implementation of access function for single-stream (not joins).
class	AggregationStateSortedJoin Implementation of access function for single-stream (not joins).
class	AggregationStateSortedJoinWFilter Implementation of access function for single-stream (not joins).
class	AggregationStateSortedWFilter

Methods in com.espertech.esper.epl.agg.access with parameters of type AggregationState

Modifier and Type	Method and Description
void	AggregationAgentRewriteStreamWFilter.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentRewriteStream.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentDefaultWFilter.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentDefault.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgent.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentRewriteStreamWFilter.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentRewriteStream.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentDefaultWFilter.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgentDefault.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	AggregationAgent.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
EventBean	AggregationAccessorWindowWEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorWindowNoEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorSortedTable.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorSortedNonTable.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorMinMaxByBase.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorLastWEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorLastNoEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorFirstWEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorFirstNoEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorFirstLastIndexWEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessorFirstLastIndexNoEval.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	AggregationAccessor.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a single event.
Collection<EventBean>	AggregationAccessorWindowWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorWindowNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorSortedTable.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorSortedNonTable.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorMinMaxByBase.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<EventBean>	AggregationAccessorLastWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorLastNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorFirstWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorFirstNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorFirstLastIndexWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessorFirstLastIndexNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	AggregationAccessor.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of events.
Collection<Object>	AggregationAccessorWindowWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorWindowNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorSortedTable.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorSortedNonTable.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorMinMaxByBase.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorLastWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorLastNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorFirstWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorFirstNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorFirstLastIndexWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessorFirstLastIndexNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	AggregationAccessor.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of scalar values.
Object	AggregationAccessorWindowWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorWindowNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorSortedTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorSortedNonTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorMinMaxByTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	AggregationAccessorMinMaxByNonTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object	AggregationAccessorLastWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorLastNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorFirstWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorFirstNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorFirstLastIndexWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessorFirstLastIndexNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	AggregationAccessor.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value either as a scalar value or any other object.

Uses of AggregationState in com.espertech.esper.epl.agg.factory

Methods in com.espertech.esper.epl.agg.factory that return AggregationState

Modifier and Type	Method and Description
AggregationState	AggregationStateFactorySorted.createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryPlugin.createAccess(int agentInstanceId, boolean join, Object groupBy, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryMinMaxByEver.createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryLinear.createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryCountMinSketch.createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)

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

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

Modifier and Type	Field and Description
protected AggregationState[]	AggSvcGroupByWTableBase.currentAggregatorStates
protected AggregationState[]	AggSvcGroupAllMixedAccessImpl.states
protected AggregationState[]	AggSvcGroupAllAccessOnlyImpl.states
protected AggregationState[]	AggSvcGroupLocalGroupByBase.statesTopLevel

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

Modifier and Type	Method and Description
AggregationState	AggregationStateFactory.createAccess(int agentInstanceId, boolean join, Object groupKey, AggregationServicePassThru passThru)
AggregationState[]	AggregationRowPair.getStates() Returns states to data window state.
AggregationState[]	AggregationMethodRowAged.getStates() Returns the states for first/last/window aggregation functions.
AggregationState[]	AggregationMethodPairRow.getStates() Returns the states for first/last/window aggregation functions.
AggregationState[]	AggSvcGroupLocalGroupByBase.getStatesTopLevel()
static AggregationState[]	AggSvcGroupByUtil.newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs, Object groupKey, AggregationServicePassThru passThru)

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

Modifier and Type	Method and Description
static void	AggSvcGroupLocalGroupByBase.aggregateIntoEnter(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
static void	AggSvcGroupLocalGroupByBase.aggregateIntoLeave(AggregationLocalGroupByLevel level, AggregationMethod[] methods, AggregationState[] states, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
protected static void	AggSvcGroupLocalGroupByBase.clearResults(Map<Object,AggregationMethodPairRow>[] aggregatorsPerLevelAndGroup, AggregationMethod[] aggregatorsTopLevel, AggregationState[] statesTopLevel)
void	AggSvcGroupLocalGroupByBase.setStatesTopLevel(AggregationState[] statesTopLevel)

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

Constructor and Description
AggregationMethodPairRow(long refcount, AggregationMethod[] methods, AggregationState[] states) Ctor.
AggregationMethodRowAged(long refcount, long lastUpdateTime, AggregationMethod[] methods, AggregationState[] states) Ctor.
AggregationRowPair(AggregationMethod[] methods, AggregationState[] states) Ctor.
AggSvcGroupAllAccessOnlyImpl(AggregationAccessorSlotPair[] accessors, AggregationState[] states, AggregationStateFactory[] accessAggSpecs)
AggSvcGroupAllMixedAccessImpl(ExprEvaluator[] evaluators, AggregationMethod[] aggregators, AggregationAccessorSlotPair[] accessors, AggregationState[] states, AggregationMethodFactory[] aggregatorFactories, AggregationStateFactory[] accessAggregations)
AggSvcGroupByRefcountedWAccessRollupImpl(ExprEvaluator[] evaluators, AggregationMethodFactory[] prototypes, AggregationAccessorSlotPair[] accessors, AggregationStateFactory[] accessAggregations, boolean isJoin, AggregationGroupByRollupDesc rollupLevelDesc, AggregationMethod[] topGroupAggregators, AggregationState[] topGroupStates) Ctor.

Uses of AggregationState in com.espertech.esper.epl.approx

Classes in com.espertech.esper.epl.approx that implement AggregationState

Modifier and Type	Class and Description
class	CountMinSketchAggState

Methods in com.espertech.esper.epl.approx with parameters of type AggregationState

Modifier and Type	Method and Description
void	CountMinSketchAggAgentAddFilter.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	CountMinSketchAggAgentAdd.applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
void	CountMinSketchAggAgentAdd.applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
EventBean	CountMinSketchAggAccessorTopk.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	CountMinSketchAggAccessorFrequency.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	CountMinSketchAggAccessorDefault.getEnumerableEvent(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	CountMinSketchAggAccessorTopk.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	CountMinSketchAggAccessorFrequency.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	CountMinSketchAggAccessorDefault.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	CountMinSketchAggAccessorTopk.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	CountMinSketchAggAccessorFrequency.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Collection<Object>	CountMinSketchAggAccessorDefault.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	CountMinSketchAggAccessorTopk.getValue(AggregationState aggregationState, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	CountMinSketchAggAccessorFrequency.getValue(AggregationState aggregationState, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object	CountMinSketchAggAccessorDefault.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)

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

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

Modifier and Type	Method and Description
void	InstrumentationDefault.aAggAccessEnterLeave(boolean enter, int index, AggregationState state)
void	Instrumentation.aAggAccessEnterLeave(boolean enter, int index, AggregationState state)
void	InstrumentationDefault.qAggAccessEnterLeave(boolean enter, int index, AggregationState state, ExprNode aggExpr)
void	Instrumentation.qAggAccessEnterLeave(boolean enter, int index, AggregationState state, ExprNode aggExpr)

Uses of AggregationState in com.espertech.esper.plugin

Methods in com.espertech.esper.plugin that return AggregationState

Modifier and Type	Method and Description
AggregationState	PlugInAggregationMultiFunctionStateFactory.makeAggregationState(PlugInAggregationMultiFunctionStateContext stateContext) Return a new aggregation state holder for a given group (or ungrouped if there is no group-by).