Package | Description |
---|---|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
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.util |
Aggregation utility classes centered around local group-by parameters.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregationStateFactoryCountMinSketch |
class |
AggregationStateLinearFactory |
class |
AggregationStateMinMaxByEverFactory |
class |
AggregationStatePluginFactory |
class |
AggregationStateSortedFactory |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory |
AggregationStateSortedForge.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationStateFactory |
AggregationStatePluginForge.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationStateFactory |
AggregationStateMinMaxByEverForge.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationStateFactory |
AggregationStateLinearForge.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
AggregationStateFactory |
AggregationStateFactoryCountMinSketch.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Field and Description |
---|---|
static AggregationStateFactory[] |
AggregatorUtil.ACCESSAGG_EMPTY_STATEFACTORY |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory[] |
AggregationRowStateEvalDesc.getAccessFactories() |
static AggregationStateFactory[] |
AggregatorUtil.getAccesssFactoriesFromForges(AggregationStateFactoryForge[] accessFactories,
StatementContext stmtContext,
boolean isFireAndForget) |
AggregationStateFactory |
AggregationStateFactoryForge.makeFactory(EngineImportService engineImportService,
boolean isFireAndForget,
java.lang.String statementName) |
Modifier and Type | Method and Description |
---|---|
static AggregationState[] |
AggSvcGroupByUtil.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
java.lang.Object groupKey,
AggregationServicePassThru passThru) |
Constructor and Description |
---|
AggregationRowStateEvalDesc(ExprEvaluator[] methodEvals,
AggregationMethodFactory[] methodFactories,
AggregationAccessorSlotPair[] accessAccessors,
AggregationStateFactory[] accessFactories) |
Modifier and Type | Field and Description |
---|---|
protected AggregationStateFactory[] |
AggSvcGroupAllFactory.accessAggSpecs |
Modifier and Type | Field and Description |
---|---|
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedWAccessImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByRefcountedFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByReclaimAgedImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByReclaimAgedFactory.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByNoReclaimMixedAccessImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByNoReclaimFactory.accessAggregations |
Modifier and Type | Field and Description |
---|---|
protected AggregationStateFactory[] |
AggSvcGroupByRollupImpl.accessAggregations |
protected AggregationStateFactory[] |
AggSvcGroupByRollupFactory.accessAggregations |
Constructor and Description |
---|
AggSvcGroupByRollupImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
AggregationGroupByRollupDesc rollupLevelDesc,
AggregationMethod[] topGroupAggregators,
AggregationState[] topGroupStates)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory[] |
AggregationLocalGroupByLevel.getStateFactories() |
Constructor and Description |
---|
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
java.lang.Class[] partitionEvaluatorsTypes,
boolean defaultLevel) |
Constructor and Description |
---|
TableStateRowFactory(ObjectArrayEventType objectArrayEventType,
EngineImportService engineImportService,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
int[] groupKeyIndexes,
EventAdapterService eventAdapterService) |