Package | Description |
---|---|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
com.espertech.esper.epl.agg.service.common |
Aggregation services - common.
|
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.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupDesc |
GroupByRollupPlanDesc.getRollupDesc() |
Constructor and Description |
---|
GroupByRollupPlanDesc(ExprNode[] expressions,
AggregationGroupByRollupDesc rollupDesc) |
Modifier and Type | Method and Description |
---|---|
static AggregationGroupByRollupDesc |
AggregationGroupByRollupDesc.make(int[][] indexes) |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc rollupDesc,
AggregationRowStateForgeDesc rowStateDesc,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
java.util.List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
java.lang.String statementName,
TimeAbacus timeAbacus) |
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) |
Modifier and Type | Field and Description |
---|---|
protected AggregationGroupByRollupDesc |
AggSvcGroupByRollupFactory.groupByRollupDesc |
protected AggregationGroupByRollupDesc |
AggSvcGroupByRollupForge.rollupDesc |
protected AggregationGroupByRollupDesc |
AggSvcGroupByRollupImpl.rollupLevelDesc |
Constructor and Description |
---|
AggSvcGroupByRollupFactory(AggregationRowStateEvalDesc eval,
boolean isJoin,
AggregationGroupByRollupDesc groupByRollupDesc) |
AggSvcGroupByRollupForge(AggregationRowStateForgeDesc rowStateForgeDesc,
boolean isJoin,
AggregationGroupByRollupDesc rollupDesc) |
AggSvcGroupByRollupImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean isJoin,
AggregationGroupByRollupDesc rollupLevelDesc,
AggregationMethod[] topGroupAggregators,
AggregationState[] topGroupStates)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static CodegenMethodNode |
AggSvcGroupByWTableRollupSingleKeyImpl.applyRollupCodegen(boolean enter,
CodegenMethodNode parent,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates,
AggregationGroupByRollupDesc groupByRollupDesc,
int numTableKeys) |
static CodegenMethodNode |
AggSvcGroupByWTableRollupMultiKeyImpl.applyRollupCodegen(boolean enter,
CodegenMethodNode parent,
CodegenClassScope classScope,
CodegenNamedMethods namedMethods,
TableColumnMethodPair[] methodPairs,
AggregationAgentForge[] agentForges,
AggregationAgent[] agents,
int[] targetStates,
AggregationGroupByRollupDesc groupByRollupDesc,
int numTableKeys) |
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupDesc |
GroupByRollupInfo.getRollupDesc() |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
java.lang.Class[] groupKeyTypes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
java.lang.Class[] groupKeyTypes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
Constructor and Description |
---|
GroupByRollupInfo(ExprNode[] exprNodes,
AggregationGroupByRollupDesc rollupDesc) |
Modifier and Type | Method and Description |
---|---|
AggregationGroupByRollupDesc |
ResultSetProcessorRowPerGroupRollupImpl.getGroupByRollupDesc() |
AggregationGroupByRollupDesc |
ResultSetProcessorRowPerGroupRollupForge.getGroupByRollupDesc() |
AggregationGroupByRollupDesc |
ResultSetProcessorRowPerGroupRollupFactory.getGroupByRollupDesc() |
AggregationGroupByRollupDesc |
ResultSetProcessorRowPerGroupRollup.getGroupByRollupDesc() |
Modifier and Type | Method and Description |
---|---|
static EventsAndSortKeysPair |
ResultSetProcessorRowPerGroupRollupUtil.getOldEventsSortKeys(int oldEventCount,
EventArrayAndSortKeyArray rstreamEventSortArrayBuf,
OrderByProcessor orderByProcessor,
AggregationGroupByRollupDesc rollupDesc) |
static ResultSetProcessorGroupedOutputFirstHelper[] |
ResultSetProcessorRowPerGroupRollupUtil.initializeOutputFirstHelpers(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
java.lang.Class[] groupKeyTypes,
AggregationGroupByRollupDesc groupByRollupDesc,
OutputConditionPolledFactory outputConditionPolledFactory)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Constructor and Description |
---|
ResultSetProcessorRowPerGroupRollupFactory(EventType resultEventType,
GroupByRollupPerLevelExpression perLevelExpression,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams,
boolean unbounded) |
ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType,
GroupByRollupPerLevelForge perLevelForges,
ExprNode[] groupKeyNodeExpressions,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams) |