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.service	Aggregation services.
com.espertech.esper.epl.approx	Approximation algos.
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.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.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	AggregationStateFactoryPlugin.createAccess(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId, boolean join, java.lang.Object groupBy)
AggregationState	AggregationStateFactory.createAccess(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId, boolean join, java.lang.Object groupKey)
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()

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

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.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, java.lang.Object groupKeyBinding, MethodResolutionService methodResolutionService, 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 that return AggregationState

AggregationState

CountMinSketchAggStateFactory.createAccess(MethodResolutionService methodResolutionService, int agentInstanceId, int groupId, int aggregationId, boolean join, java.lang.Object groupKey)

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.epl.core

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

AggregationState	MethodResolutionServiceImpl.makeAccessAggLinearJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	MethodResolutionService.makeAccessAggLinearJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	MethodResolutionServiceImpl.makeAccessAggLinearNonJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	MethodResolutionService.makeAccessAggLinearNonJoin(int agentInstanceId, int groupId, int aggregationId, int streamNum)
AggregationState	MethodResolutionServiceImpl.makeAccessAggMinMaxEver(int agentInstanceId, int groupId, int aggregationId, AggregationStateMinMaxByEverSpec spec)
AggregationState	MethodResolutionService.makeAccessAggMinMaxEver(int agentInstanceId, int groupId, int aggregationId, AggregationStateMinMaxByEverSpec spec)
AggregationState	MethodResolutionServiceImpl.makeAccessAggPlugin(int agentInstanceId, int groupId, int aggregationId, boolean join, PlugInAggregationMultiFunctionStateFactory providerFactory, java.lang.Object groupKey)
AggregationState	MethodResolutionService.makeAccessAggPlugin(int agentInstanceId, int groupId, int aggregationId, boolean join, PlugInAggregationMultiFunctionStateFactory providerFactory, java.lang.Object groupKey)
AggregationState	MethodResolutionServiceImpl.makeAccessAggSortedJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationState	MethodResolutionService.makeAccessAggSortedJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationState	MethodResolutionServiceImpl.makeAccessAggSortedNonJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationState	MethodResolutionService.makeAccessAggSortedNonJoin(int agentInstanceId, int groupId, int aggregationId, AggregationStateSortedSpec spec)
AggregationState	MethodResolutionServiceImpl.makeCountMinSketch(int agentInstanceId, int groupId, int aggregationId, CountMinSketchSpec specification)
AggregationState	MethodResolutionService.makeCountMinSketch(int agentInstanceId, int groupId, int aggregationId, CountMinSketchSpec specification)
AggregationState[]	MethodResolutionServiceImpl.newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs)
AggregationState[]	MethodResolutionService.newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs)
AggregationState[]	MethodResolutionServiceImpl.newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel)
AggregationState[]	MethodResolutionService.newAccesses(int agentInstanceId, boolean isJoin, AggregationStateFactory[] accessAggSpecs, java.lang.Object groupKey, java.lang.Object groupKeyBinding, AggregationGroupByRollupLevel groupByRollupLevel)

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

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.

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).