Package | Description |
---|---|
com.espertech.esper.epl.agg.service.common |
Aggregation services - common.
|
com.espertech.esper.epl.core.resultset.codegen |
Result set processor code generation classes
|
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorFactoryDesc |
ResultSetProcessorFactoryCompiler.allocate(ResultSetProcessorFactoryForge forge,
ResultSetProcessorType resultSetProcessorType,
EventType resultEventType,
StatementContext stmtContext,
boolean isFireAndForget,
boolean join,
boolean hasOutputLimit,
ResultSetProcessorOutputConditionType outputConditionType,
boolean hasOutputLimitSnapshot,
SelectExprProcessorForge[] selectExprProcessorForge,
boolean rollup,
AggregationServiceForgeDesc aggregationServiceForgeDesc,
OrderByProcessorFactoryForge orderByProcessorForge) |