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

Packages that use AggregationState

com.espertech.esper.epl.agg.access	State multifunction aggregation methods
com.espertech.esper.epl.agg.factory
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

interface

AggregationStateWithSize

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

class	AggregationStateImpl Implementation of access function for single-stream (not joins).
class	AggregationStateJoinImpl Implementation of access function for joins.
class	AggregationStateMinMaxByEver Implementation of access function for single-stream (not joins).
class	AggregationStateSortedImpl Implementation of access function for single-stream (not joins).
class	AggregationStateSortedJoin Implementation of access function for single-stream (not joins).

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

void	AggregationAgentRewriteStream.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	AggregationAgentRewriteStream.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.
java.util.Collection<EventBean>	AggregationAccessorWindowWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorWindowNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorSortedTable.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorSortedNonTable.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorMinMaxByBase.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.util.Collection<EventBean>	AggregationAccessorLastWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorLastNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorFirstWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorFirstNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorFirstLastIndexWEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessorFirstLastIndexNoEval.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	AggregationAccessor.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of events.
java.util.Collection<java.lang.Object>	AggregationAccessorWindowWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorWindowNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorSortedTable.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorSortedNonTable.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorMinMaxByBase.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorLastWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorLastNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorFirstWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorFirstNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorFirstLastIndexWEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessorFirstLastIndexNoEval.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	AggregationAccessor.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Return the aggregation state value consisting of a collection of scalar values.
java.lang.Object	AggregationAccessorWindowWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorWindowNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorSortedTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorSortedNonTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorMinMaxByTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Object	AggregationAccessorMinMaxByNonTable.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Object	AggregationAccessorLastWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorLastNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorFirstWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorFirstNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorFirstLastIndexWEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	AggregationAccessorFirstLastIndexNoEval.getValue(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.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

AggregationState	AggregationStateFactorySorted.createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryPlugin.createAccess(int agentInstanceId, boolean join, java.lang.Object groupBy, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryMinMaxByEver.createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryLinear.createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
AggregationState	AggregationStateFactoryCountMinSketch.createAccess(int agentInstanceId, boolean join, java.lang.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

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

AggregationState	AggregationStateFactory.createAccess(int agentInstanceId, boolean join, java.lang.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, java.lang.Object groupKey, AggregationServicePassThru passThru)

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

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(java.util.Map<java.lang.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

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

class

CountMinSketchAggState

Methods in com.espertech.esper.epl.approx with parameters of type 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)
java.util.Collection<EventBean>	CountMinSketchAggAccessorTopk.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	CountMinSketchAggAccessorFrequency.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	CountMinSketchAggAccessorDefault.getEnumerableEvents(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	CountMinSketchAggAccessorTopk.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	CountMinSketchAggAccessorFrequency.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<java.lang.Object>	CountMinSketchAggAccessorDefault.getEnumerableScalar(AggregationState state, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	CountMinSketchAggAccessorTopk.getValue(AggregationState aggregationState, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	CountMinSketchAggAccessorFrequency.getValue(AggregationState aggregationState, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.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

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

AggregationState

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