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.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   
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
 EventBean AggregationAccessorSorted.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessorMinMaxBy.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessorLast.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessorFirstLastIndex.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessorFirst.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessorAll.getEnumerableEvent(AggregationState state)
           
 EventBean AggregationAccessor.getEnumerableEvent(AggregationState state)
          Return the aggregation state value consisting of a single event.
 java.util.Collection<EventBean> AggregationAccessorSorted.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessorMinMaxBy.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessorLast.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessorFirstLastIndex.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessorFirst.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessorAll.getEnumerableEvents(AggregationState state)
           
 java.util.Collection<EventBean> AggregationAccessor.getEnumerableEvents(AggregationState state)
          Return the aggregation state value consisting of a collection of events.
 java.lang.Object AggregationAccessorSorted.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessorMinMaxBy.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessorLast.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessorFirstLastIndex.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessorFirst.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessorAll.getValue(AggregationState state)
           
 java.lang.Object AggregationAccessor.getValue(AggregationState state)
          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[] AggSvcGroupAllMixedAccessImpl.states
           
protected  AggregationState[] AggSvcGroupAllAccessOnlyImpl.states
           
 

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.
 

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.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.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, AggregationStateFactory accessAggSpec)
           
 void Instrumentation.qAggAccessEnterLeave(boolean enter, int index, AggregationState state, AggregationStateFactory accessAggSpec)
           
 

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


© 2006-2014 EsperTech Inc.
All rights reserved.
Visit us at espertech.com