|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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)
|
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)
|
AggregationState[] |
MethodResolutionService.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
java.lang.Object groupKey,
java.lang.Object groupKeyBinding)
|
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 |
|||||||||
PREV NEXT | FRAMES NO FRAMES |