Package | Description |
---|---|
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.groupbyrollup |
Aggregation services - rollup.
|
com.espertech.esper.epl.agg.service.table |
Aggregation services - table aggregation.
|
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 |
---|---|
static AggregationAccessorSlotPair[] |
AggregatorUtil.ACCESSAGG_EMPTY_ACCESSORS |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPair[] |
AggregationRowStateEvalDesc.getAccessAccessors() |
static AggregationAccessorSlotPair |
AggregatorUtil.getAccessorForForge(AggregationAccessorSlotPairForge pair,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
static AggregationAccessorSlotPair[] |
AggregatorUtil.getAccessorsForForges(AggregationAccessorSlotPairForge[] accessors,
EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getTable(TableService tableService,
TableMetadata tableMetadata,
TableColumnMethodPair[] methodPairs,
AggregationAccessorSlotPairForge[] accessorPairs,
AggregationAccessorSlotPair[] accessors,
boolean join,
int[] targetStates,
ExprNode[] accessStateExpr,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean hasGroupBy) |
Constructor and Description |
---|
AggregationRowStateEvalDesc(ExprEvaluator[] methodEvals,
AggregationMethodFactory[] methodFactories,
AggregationAccessorSlotPair[] accessAccessors,
AggregationStateFactory[] accessFactories) |
Modifier and Type | Field and Description |
---|---|
protected AggregationAccessorSlotPair[] |
AggSvcGroupAllFactory.accessors |
Modifier and Type | Field and Description |
---|---|
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedWAccessImpl.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRefcountedFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByReclaimAgedFactory.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByNoReclaimFactory.accessors |
Modifier and Type | Field and Description |
---|---|
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRollupImpl.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupByRollupFactory.accessors |
Constructor and Description |
---|
AggSvcGroupByRollupImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
AggregationGroupByRollupDesc rollupLevelDesc,
AggregationMethod[] topGroupAggregators,
AggregationState[] topGroupStates)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationAccessorSlotPair[] |
AggSvcGroupByWTableBase.accessors |
protected AggregationAccessorSlotPair[] |
AggSvcGroupAllWTableFactory.accessors |
Modifier and Type | Method and Description |
---|---|
static void |
AggSvcGroupAllWTableImpl.getGroupAllValueCodegen(AggSvcTableGetterType getterType,
CodegenMethodNode method,
CodegenClassScope classScope,
AggregationAccessorSlotPair[] accessors) |
static void |
AggSvcGroupByWTableBase.getGroupByValueCodegen(AggSvcTableGetterType getterType,
CodegenMethodNode method,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods,
int numMethodAggs,
AggregationAccessorSlotPair[] accessors) |
Modifier and Type | Method and Description |
---|---|
AggregationAccessorSlotPair |
AggregationLocalGroupByColumn.getPair() |
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(java.lang.String columnName,
AggregationMethodFactory factory,
int methodOffset,
AggregationAccessorSlotPair accessAccessorSlotPair,
EPType optionalEnumerationType,
EventType optionalEventType) |
Modifier and Type | Method and Description |
---|---|
protected static java.lang.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 java.util.Collection<EventBean> |
ExprTableEvalStrategyUtil.evalGetROCollectionEvents(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static java.util.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,
java.lang.String tableName,
java.lang.String subpropName,
int streamNum,
java.lang.Class returnType,
AggregationAccessorSlotPair accessAccessorSlotPair,
EventType eventTypeColl) |