Methods in com.espertech.esper.epl.agg.factory that return AggregationStateFactory |
AggregationStateFactory |
AggregationMethodFactorySum.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryStddev.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryRate.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryPlugIn.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryNth.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryMinMax.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryMedian.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryLeaving.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryLastEver.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryFirstEver.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryCountEver.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryCount.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryAvg.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationMethodFactoryAvedev.getAggregationStateFactory(boolean isMatchRecognize)
|
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum)
|
AggregationStateFactory |
AggregationFactoryFactory.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum)
|
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeMinMaxEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateMinMaxByEverSpec spec)
|
AggregationStateFactory |
AggregationFactoryFactory.makeMinMaxEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateMinMaxByEverSpec spec)
|
AggregationStateFactory |
AggregationFactoryFactoryDefault.makePlugInAccess(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggMultiFunctionNodeFactory factory)
|
AggregationStateFactory |
AggregationFactoryFactory.makePlugInAccess(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggMultiFunctionNodeFactory factory)
|
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeSorted(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateSortedSpec spec)
|
AggregationStateFactory |
AggregationFactoryFactory.makeSorted(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateSortedSpec spec)
|
Methods in com.espertech.esper.epl.agg.service with parameters of type AggregationStateFactory |
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,
java.lang.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,
java.lang.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.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)
|
static AggregationState[] |
AggSvcGroupByUtil.newAccesses(int agentInstanceId,
boolean isJoin,
AggregationStateFactory[] accessAggSpecs,
java.lang.Object groupKey,
AggregationServicePassThru passThru)
|
Constructors in com.espertech.esper.epl.agg.service with parameters of type AggregationStateFactory |
AggregationMultiFunctionAnalysisResult(AggregationAccessorSlotPair[] accessorPairs,
AggregationStateFactory[] stateFactories)
|
AggregationServiceBaseUngrouped(ExprEvaluator[] evaluators,
AggregationMethod[] aggregators,
AggregationMethodFactory[] aggregatorFactories,
AggregationStateFactory[] accessAggregations)
Ctor. |
AggSvcGroupAllAccessOnlyFactory(AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggSpecs,
boolean join)
|
AggSvcGroupAllAccessOnlyImpl(AggregationAccessorSlotPair[] accessors,
AggregationState[] states,
AggregationStateFactory[] accessAggSpecs)
|
AggSvcGroupAllMixedAccessFactory(ExprEvaluator[] evaluators,
AggregationMethodFactory[] aggregators,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean join)
|
AggSvcGroupAllMixedAccessImpl(ExprEvaluator[] evaluators,
AggregationMethod[] aggregators,
AggregationAccessorSlotPair[] accessors,
AggregationState[] states,
AggregationMethodFactory[] aggregatorFactories,
AggregationStateFactory[] accessAggregations)
|
AggSvcGroupByAccessOnlyFactory(AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggSpecs,
boolean isJoin)
Ctor. |
AggSvcGroupByAccessOnlyImpl(AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggSpecs,
boolean isJoin)
Ctor. |
AggSvcGroupByMixedAccessFactory(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin)
Ctor. |
AggSvcGroupByMixedAccessImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessorsFactory,
AggregationStateFactory[] accessAggregations,
boolean isJoin)
Ctor. |
AggSvcGroupByReclaimAgedFactory(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
java.lang.String optionalContextName)
Ctor. |
AggSvcGroupByReclaimAgedImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] aggregators,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean join,
AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionMaxAge,
AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionFrequency)
|
AggSvcGroupByRefcountedWAccessFactory(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin)
Ctor. |
AggSvcGroupByRefcountedWAccessImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin)
Ctor. |
AggSvcGroupByRefcountedWAccessRollupFactory(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
AggregationGroupByRollupDesc groupByRollupDesc)
Ctor. |
AggSvcGroupByRefcountedWAccessRollupImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
AggregationGroupByRollupDesc rollupLevelDesc,
AggregationMethod[] topGroupAggregators,
AggregationState[] topGroupStates)
Ctor. |