Package | Description |
---|---|
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.table.mgmt |
Table-related services and metadata.
|
com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationAccessorSlotPair[] |
AggSvcGroupByWTableBase.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedWAccessRollupImpl.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedWAccessRollupFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedWAccessImpl.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedWAccessFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByReclaimAgedFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByMixedAccessFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupAllMixedAccessWTableFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupAllMixedAccessFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupAllAccessOnlyFactory.accessors |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPair[] |
AggregationMultiFunctionAnalysisResult.getAccessorPairs() |
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.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupWBinding(TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPair[] accessorPairs,
boolean join,
IntoTableSpec bindings,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc) |
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) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupWBinding(AggregationAccessorSlotPair[] accessors,
boolean join,
TableColumnMethodPair[] methodPairs,
String tableName,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgent[] agents) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPair |
AggregationLocalGroupByColumn.getPair() |
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 |
---|
AggregationLocalGroupByColumn(boolean defaultGroupLevel,
ExprEvaluator[] partitionEvaluators,
int methodOffset,
boolean methodAgg,
AggregationAccessorSlotPair pair,
int levelNum) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPair |
TableMetadataColumnAggregation.getAccessAccessorSlotPair() |
Constructor and Description |
---|
TableMetadataColumnAggregation(String columnName,
AggregationMethodFactory factory,
int methodOffset,
AggregationAccessorSlotPair accessAccessorSlotPair,
EPType optionalEnumerationType,
EventType optionalEventType) |
Modifier and Type | Method and Description |
---|---|
protected static Object |
ExprTableEvalStrategyUtil.evalAccessorGetValue(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static EventBean |
ExprTableEvalStrategyUtil.evalGetEventBean(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection<EventBean> |
ExprTableEvalStrategyUtil.evalGetROCollectionEvents(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection |
ExprTableEvalStrategyUtil.evalGetROCollectionScalar(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Constructor and Description |
---|
ExprTableEvalStrategyGroupByAccessBase(TableAndLockProviderGrouped provider,
AggregationAccessorSlotPair pair) |
ExprTableEvalStrategyGroupByAccessMulti(TableAndLockProviderGrouped provider,
AggregationAccessorSlotPair pair,
ExprEvaluator[] groupExpr) |
ExprTableEvalStrategyGroupByAccessSingle(TableAndLockProviderGrouped provider,
AggregationAccessorSlotPair pair,
ExprEvaluator groupExpr) |
ExprTableExprEvaluatorAccess(ExprNode exprNode,
String tableName,
String subpropName,
int streamNum,
Class returnType,
AggregationAccessorSlotPair accessAccessorSlotPair,
EventType eventTypeColl) |