Package | Description |
---|---|
com.espertech.esper.epl.agg.codegen |
Byte-Code-Generation classes for aggregation service and related
|
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.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.expression.baseagg |
Base aggregation expressions.
|
com.espertech.esper.epl.expression.methodagg |
Method-aggregation expressions.
|
com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory[] |
AggregationCodegenRowDetailStateDesc.getMethodFactories() |
Constructor and Description |
---|
AggregationCodegenRowDetailStateDesc(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationStateFactoryForge[] accessStateForges) |
Modifier and Type | Class and Description |
---|---|
class |
AggregationMethodFactoryAvedev |
class |
AggregationMethodFactoryAvg |
class |
AggregationMethodFactoryCount |
class |
AggregationMethodFactoryCountEver |
class |
AggregationMethodFactoryFirstLastEver |
class |
AggregationMethodFactoryLeaving |
class |
AggregationMethodFactoryMedian |
class |
AggregationMethodFactoryMinMax |
class |
AggregationMethodFactoryNth |
class |
AggregationMethodFactoryPlugIn |
class |
AggregationMethodFactoryRate |
class |
AggregationMethodFactoryStddev |
class |
AggregationMethodFactorySum |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
java.lang.Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
java.lang.Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
java.lang.Class childType,
java.math.MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
java.lang.Class childType,
java.math.MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
java.lang.Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
java.lang.Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeFirstLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstLastEverNode exprFirstLastEverNode,
java.lang.Class type) |
AggregationMethodFactory |
AggregationFactoryFactory.makeFirstLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstLastEverNode exprFirstLastEverNode,
java.lang.Class type) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLeaving(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLeavingAggNode exprLeavingAggNode) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLeaving(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLeavingAggNode exprLeavingAggNode) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLinearUnbounded(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode parent,
EventType containedType,
java.lang.Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLinearUnbounded(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode exprAggMultiFunctionLinearAccessNode,
EventType containedType,
java.lang.Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
java.lang.Class type,
boolean hasDataWindows) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
java.lang.Class type,
boolean hasDataWindows) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
java.lang.Class type,
int size) |
AggregationMethodFactory |
AggregationFactoryFactory.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
java.lang.Class type,
int size) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalTime,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
AggregationMethodFactory |
AggregationFactoryFactory.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalMsec,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeStddev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprStddevNode exprStddevNode,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeStddev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprStddevNode exprStddevNode,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
java.lang.Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
java.lang.Class childType) |
Modifier and Type | Method and Description |
---|---|
void |
AggregationMethodFactorySum.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryStddev.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryRate.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryPlugIn.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryNth.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryMinMax.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryMedian.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryLeaving.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryFirstLastEver.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryCountEver.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryCount.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryAvg.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryAvedev.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
Modifier and Type | Field and Description |
---|---|
protected AggregationMethodFactory[] |
AggregationServiceBaseGrouped.aggregators
Aggregation states and factories.
|
static AggregationMethodFactory[] |
AggregatorUtil.METHODAGG_EMPTYFACTORIES |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
AggregationServiceAggExpressionDesc.getFactory()
Returns the method factory.
|
AggregationMethodFactory[] |
AggregationRowStateForgeDesc.getMethodFactories() |
AggregationMethodFactory[] |
AggregationRowStateEvalDesc.getMethodFactories() |
Modifier and Type | Method and Description |
---|---|
static AggregationMethod[] |
AggSvcGroupByUtil.newAggregators(AggregationMethodFactory[] prototypes) |
static void |
AggregationValidationUtil.validateAggregationType(AggregationMethodFactory requiredFactory,
AggregationMethodFactory providedFactory) |
void |
AggregationMethodFactory.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
Constructor and Description |
---|
AggregationRowStateEvalDesc(ExprEvaluator[] methodEvals,
AggregationMethodFactory[] methodFactories,
AggregationAccessorSlotPair[] accessAccessors,
AggregationStateFactory[] accessFactories) |
AggregationRowStateForgeDesc(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationAccessorSlotPairForge[] accessAccessorsForges,
AggregationStateFactoryForge[] accessFactoriesForges) |
AggregationServiceAggExpressionDesc(ExprAggregateNode aggregationNode,
AggregationMethodFactory factory)
Ctor.
|
AggregationServiceBaseGrouped(ExprEvaluator[] evaluators,
AggregationMethodFactory[] aggregators)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected AggregationMethodFactory[] |
AggSvcGroupAllFactory.aggregators |
Modifier and Type | Field and Description |
---|---|
protected AggregationMethodFactory[] |
AggSvcGroupByRefcountedFactory.aggregators |
protected AggregationMethodFactory[] |
AggSvcGroupByReclaimAgedFactory.aggregators |
protected AggregationMethodFactory[] |
AggSvcGroupByNoReclaimFactory.aggregators |
Modifier and Type | Field and Description |
---|---|
protected AggregationMethodFactory[] |
AggSvcGroupByRollupFactory.aggregators |
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 |
---|---|
AggregationMethodFactory[] |
AggregationLocalGroupByLevelForge.getMethodFactories() |
AggregationMethodFactory[] |
AggregationLocalGroupByLevel.getMethodFactories() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlanForge |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationStateFactoryForge[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPairForge[] accessors,
EngineImportService engineImportService,
boolean fireAndForget,
java.lang.String statementName) |
Constructor and Description |
---|
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
java.lang.Class[] partitionEvaluatorsTypes,
boolean defaultLevel) |
AggregationLocalGroupByLevelForge(ExprForge[][] methodForges,
AggregationMethodFactory[] methodFactories,
AggregationStateFactoryForge[] accessStateForges,
ExprForge[] partitionForges,
boolean defaultLevel) |
Modifier and Type | Class and Description |
---|---|
class |
AggregationMethodFactoryFirstLastUnbound |
class |
ExprAggCountMinSketchNodeFactoryBase |
class |
ExprAggCountMinSketchNodeFactoryState |
class |
ExprAggCountMinSketchNodeFactoryUse |
class |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess |
class |
ExprAggMultiFunctionSortedMinMaxByNodeFactory |
class |
ExprPlugInAggMultiFunctionNodeFactory |
Modifier and Type | Method and Description |
---|---|
void |
ExprPlugInAggMultiFunctionNodeFactory.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
ExprAggCountMinSketchNodeFactoryUse.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
ExprAggCountMinSketchNodeFactoryState.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryFirstLastUnbound.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
Constructor and Description |
---|
LinearAggregationFactoryDesc(AggregationMethodFactory factory,
EventType enumerationEventType,
java.lang.Class scalarCollectionType) |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
ExprAggregateNodeBase.getFactory()
Returns the aggregation state factory for use in grouping aggregation states per group-by keys.
|
AggregationMethodFactory |
ExprAggregateNode.getFactory() |
protected abstract AggregationMethodFactory |
ExprAggregateNodeBase.validateAggregationChild(ExprValidationContext validationContext)
Gives the aggregation node a chance to validate the sub-expression types.
|
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
TableMetadataColumnAggregation.getFactory() |
Constructor and Description |
---|
TableMetadataColumnAggregation(java.lang.String columnName,
AggregationMethodFactory factory,
int methodOffset,
AggregationAccessorSlotPair accessAccessorSlotPair,
EPType optionalEnumerationType,
EventType optionalEventType) |
TableStateRowFactory(ObjectArrayEventType objectArrayEventType,
EngineImportService engineImportService,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
int[] groupKeyIndexes,
EventAdapterService eventAdapterService) |