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.common |
Aggregation services - common.
|
com.espertech.esper.epl.agg.service.groupall |
Aggregation services group-all.
|
com.espertech.esper.epl.agg.service.groupby |
Aggregation services group-by regular
|
com.espertech.esper.epl.agg.service.groupbylocal |
Aggregation services - local-grouping
|
com.espertech.esper.epl.agg.service.groupbyrollup |
Aggregation services - rollup.
|
com.espertech.esper.epl.agg.service.table |
Aggregation services - table aggregation.
|
com.espertech.esper.epl.core.orderby |
Order-by and row-limit processors
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
Modifier and Type | Method and Description |
---|---|
void |
AIRegistryAggregationSingle.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AIRegistryAggregationMultiPerm.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AIRegistryAggregationMap.setCurrentAccess(java.lang.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,
java.lang.Object groupKey) |
GroupByRollupLevelEventPair(AggregationGroupByRollupLevel level,
EventBean event) |
GroupByRollupLevelKeyPair(AggregationGroupByRollupLevel level,
java.lang.Object key) |
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupLevel[] |
AggregationGroupByRollupDesc.getLevels() |
Modifier and Type | Method and Description |
---|---|
void |
AggregationServiceTable.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggregationServiceNull.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggregationService.setCurrentAccess(java.lang.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 |
AggSvcGroupAllImplNoAccess.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllImplMixedAccess.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllImplAccessOnly.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByRefcountedWAccessImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByRefcountedNoAccessImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByReclaimAgedImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByNoReclaimNoAccessImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByNoReclaimMixedAccessImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByNoReclaimAccessOnlyImpl.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByLocalGroupBy.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllLocalGroupBy.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByRollupImpl.internalHandleGroupRemove(java.lang.Object groupByKey,
AggregationGroupByRollupLevel groupByRollupLevel) |
void |
AggSvcGroupByRollupImpl.internalHandleGroupUpdate(java.lang.Object groupByKey,
AggregationMethodPairRow row,
AggregationGroupByRollupLevel groupByRollupLevel) |
void |
AggSvcGroupByRollupImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
void |
AggSvcGroupByWTableRollupMultiKeyImpl.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupByWTableBase.setCurrentAccess(java.lang.Object groupByKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
void |
AggSvcGroupAllWTableImpl.setCurrentAccess(java.lang.Object groupKey,
int agentInstanceId,
AggregationGroupByRollupLevel rollupLevel) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
OrderByProcessorRowLimitOnly.getSortKeyRollup(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
AggregationGroupByRollupLevel level) |
java.lang.Object |
OrderByProcessorOrderedLimit.getSortKeyRollup(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
AggregationGroupByRollupLevel level) |
java.lang.Object |
OrderByProcessorImpl.getSortKeyRollup(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
AggregationGroupByRollupLevel level) |
java.lang.Object |
OrderByProcessor.getSortKeyRollup(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
AggregationGroupByRollupLevel level)
Returns the sort key for a given row for rollup.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultSetProcessorRowPerGroupRollupImpl.generateOutputBatched(java.lang.Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> resultEvents,
java.util.List<java.lang.Object> optSortKeys) |
void |
ResultSetProcessorRowPerGroupRollup.generateOutputBatched(java.lang.Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> resultEvents,
java.util.List<java.lang.Object> optSortKeys) |
void |
ResultSetProcessorRowPerGroupRollupImpl.generateOutputBatchedMapUnsorted(boolean join,
java.lang.Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
java.util.Map<java.lang.Object,EventBean> resultEvents) |
void |
ResultSetProcessorRowPerGroupRollup.generateOutputBatchedMapUnsorted(boolean join,
java.lang.Object mk,
AggregationGroupByRollupLevel level,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
java.util.Map<java.lang.Object,EventBean> resultEvents) |