Package | Description |
---|---|
com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
AIRegistryAggregationSingle.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AIRegistryAggregationMultiPerm.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AIRegistryAggregationMap.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupLevel |
GroupByRollupLevelKeyPair.getLevel() |
AggregationGroupByRollupLevel |
GroupByRollupLevelEventPair.getLevel() |
AggregationGroupByRollupLevel |
GroupByRollupKey.getLevel() |
Constructor and Description |
---|
GroupByRollupKey(EventBean[] generator,
AggregationGroupByRollupLevel level,
Object groupKey) |
GroupByRollupLevelEventPair(AggregationGroupByRollupLevel level,
EventBean event) |
GroupByRollupLevelKeyPair(AggregationGroupByRollupLevel level,
Object key) |
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupLevel[] |
AggregationGroupByRollupDesc.getLevels() |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByRefcountedWAccessRollupImpl.internalHandleGroupRemove(Object groupByKey,
AggregationGroupByRollupLevel groupByRollupLevel) |
void |
AggSvcGroupByRefcountedWAccessRollupImpl.internalHandleGroupUpdate(Object groupByKey,
AggregationMethodPairRow row,
AggregationGroupByRollupLevel groupByRollupLevel) |
void |
AggSvcGroupByWTableRollupMultiKeyImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByWTableBase.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByRefcountedWAccessRollupImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByRefcountedWAccessImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByRefcountedNoAccessImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByReclaimAgedImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByNoAccessImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByMixedAccessImpl.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByLocalGroupBy.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByAccessOnlyImpl.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllNoAccessImpl.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllMixedAccessWTableImpl.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllMixedAccessImpl.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllLocalGroupBy.setCurrentAccess(Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllAccessOnlyImpl.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggregationServiceTable.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggregationServiceNull.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggregationService.setCurrentAccess(Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel)
Set the current aggregation state row - for use when evaluation nodes are asked to evaluate.
|
Constructor and Description |
---|
AggregationGroupByRollupDesc(AggregationGroupByRollupLevel[] levels) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowPerGroupRollup.generateOutputBatched(boolean join,
Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
List<EventBean> resultEvents,
List<Object> optSortKeys) |
void |
ResultSetProcessorRowPerGroupRollup.generateOutputBatchedMapUnsorted(boolean join,
Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
Map<Object,EventBean> resultEvents) |