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.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 | Class and Description |
---|---|
class |
AggregationMethodFactoryAvedev |
class |
AggregationMethodFactoryAvg |
class |
AggregationMethodFactoryCount |
class |
AggregationMethodFactoryCountEver |
class |
AggregationMethodFactoryFirstEver |
class |
AggregationMethodFactoryLastEver |
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,
Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
Class childType,
MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
Class childType,
MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeFirstEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstEverNode exprFirstEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactory.makeFirstEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstEverNode exprFirstEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLastEverNode exprLastEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLastEverNode exprLastEverNode,
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,
Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLinearUnbounded(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode exprAggMultiFunctionLinearAccessNode,
EventType containedType,
Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
Class type,
boolean hasDataWindows) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
Class type,
boolean hasDataWindows) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
Class type,
int size) |
AggregationMethodFactory |
AggregationFactoryFactory.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
Class type,
int size) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
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,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeStddev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprStddevNode exprStddevNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
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 |
AggregationMethodFactoryLastEver.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
void |
AggregationMethodFactoryFirstEver.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[] |
AggregationServiceBaseUngrouped.aggregatorFactories |
protected AggregationMethodFactory[] |
AggregationServiceFactoryBase.aggregators
Prototype aggregation states and factories.
|
protected AggregationMethodFactory[] |
AggregationServiceBaseGrouped.aggregators
Aggregation states and factories.
|
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
AggregationServiceAggExpressionDesc.getFactory()
Returns the method factory.
|
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
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.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
static AggregationMethod[] |
AggSvcGroupByUtil.newAggregators(AggregationMethodFactory[] prototypes) |
static void |
AggregationValidationUtil.validateAggregationType(AggregationMethodFactory requiredFactory,
AggregationMethodFactory providedFactory) |
void |
AggregationMethodFactory.validateIntoTableCompatible(AggregationMethodFactory intoTableAgg) |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory[] |
AggregationLocalGroupByLevel.getMethodFactories() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlan |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationStateFactory[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPair[] accessors) |
Constructor and Description |
---|
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
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,
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(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) |