Package | Description |
---|---|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationStateFactoryCountMinSketch |
class |
AggregationStateFactoryLinear |
class |
AggregationStateFactoryMinMaxByEver |
class |
AggregationStateFactoryPlugin |
class |
AggregationStateFactorySorted |
Modifier and Type | Field and Description |
---|---|
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedWAccessRollupImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedWAccessRollupFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedWAccessImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedWAccessFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByReclaimAgedImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByReclaimAgedFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByMixedAccessImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByMixedAccessFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupAllMixedAccessFactory.accessAggregations |
protected AggregationStateFactory[] |
AggregationServiceBaseUngrouped.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupAllAccessOnlyFactory.accessAggSpecs |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory |
AggregationMethodFactory.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory[] |
AggregationMultiFunctionAnalysisResult.getStateFactories() |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimAccessOnly(ExprNode[] groupByNodes,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupAccessOnly(AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggSpecs,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
static AggregationState[] |
AggSvcGroupByUtil.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
Object groupKey,
AggregationServicePassThru passThru) |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory[] |
AggregationLocalGroupByLevel.getStateFactories() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlan |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationStateFactory[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPair[] accessors,
EngineImportService engineImportService,
boolean fireAndForget,
String statementName) |
Constructor and Description |
---|
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
Class[] partitionEvaluatorsTypes,
boolean defaultLevel) |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory |
ExprPlugInAggMultiFunctionNodeFactory.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
ExprAggCountMinSketchNodeFactoryUse.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
ExprAggCountMinSketchNodeFactoryState.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
AggregationMethodFactoryFirstLastUnbound.getAggregationStateFactory(boolean isMatchRecognize) |
AggregationStateFactory |
SortedAggregationStateFactoryFactory.makeFactory() |
Constructor and Description |
---|
ExprAggMultiFunctionLinearAccessNodeFactoryAccess(ExprAggMultiFunctionLinearAccessNode parent,
AggregationAccessor accessor,
Class accessorResultType,
EventType containedEventType,
AggregationStateKey optionalStateKey,
AggregationStateFactory optionalStateFactory,
AggregationAgent optionalAgent) |
Constructor and Description |
---|
TableStateRowFactory(ObjectArrayEventType objectArrayEventType,
EngineImportService engineImportService,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
int[] groupKeyIndexes,
EventAdapterService eventAdapterService) |