Package | Description |
---|---|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.handthru |
Result set processor for Un-Aggregated and Un-Grouped with having or output-rate-limiting or order-by
|
com.espertech.esper.epl.core.resultset.rowforall |
Result set processor for Fully-Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowperevent |
Result set processor for Aggregated and Un-Grouped
|
com.espertech.esper.epl.core.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.rowpergrouprollup |
Result set processor for Rollup
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Modifier and Type | Method and Description |
---|---|
OutputLimitSpec |
ResultSetProcessorAggregateGroupedForge.getOutputLimitSpec() |
OutputLimitSpec |
ResultSetProcessorAggregateGroupedFactory.getOutputLimitSpec() |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams) |
Constructor and Description |
---|
ResultSetProcessorSimpleFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
int numStreams) |
ResultSetProcessorSimpleForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean isSorting,
int numStreams) |
Modifier and Type | Method and Description |
---|---|
OutputLimitSpec |
ResultSetProcessorRowForAllForge.getOutputLimitSpec() |
Constructor and Description |
---|
ResultSetProcessorRowForAllFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType) |
ResultSetProcessorRowForAllForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean hasOrderBy,
ResultSetProcessorOutputConditionType outputConditionType) |
Constructor and Description |
---|
ResultSetProcessorRowPerEventFactory(EventType resultEventType,
SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
ResultSetProcessorRowPerEventForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorOutputConditionType outputConditionType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean hasOrderBy) |
Modifier and Type | Method and Description |
---|---|
OutputLimitSpec |
ResultSetProcessorRowPerGroupForge.getOutputLimitSpec() |
OutputLimitSpec |
ResultSetProcessorRowPerGroupFactory.getOutputLimitSpec() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupForge(EventType resultEventType,
SelectExprProcessorForge selectExprProcessorForge,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
ResultSetProcessorOutputConditionType outputConditionType,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
Modifier and Type | Method and Description |
---|---|
OutputLimitSpec |
ResultSetProcessorRowPerGroupRollupForge.getOutputLimitSpec() |
OutputLimitSpec |
ResultSetProcessorRowPerGroupRollupFactory.getOutputLimitSpec() |
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) |
Modifier and Type | Method and Description |
---|---|
static OutputLimitSpec |
ASTOutputLimitHelper.buildOutputLimitSpec(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.OutputLimitContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
java.lang.String engineURI,
TimeProvider timeProvider,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
OutputLimitSpec |
StatementSpecRaw.getOutputLimitSpec()
Returns the output limit definition, if any.
|
OutputLimitSpec |
StatementSpecCompiled.getOutputLimitSpec()
Returns the output limit definition, if any.
|
Modifier and Type | Method and Description |
---|---|
void |
StatementSpecRaw.setOutputLimitSpec(OutputLimitSpec outputLimitSpec)
Sets the output limiting definition.
|
Constructor and Description |
---|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
java.util.Set<java.lang.String> variableReferences,
RowLimitSpec rowLimitSpec,
java.lang.String[] eventTypeReferences,
java.lang.annotation.Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
java.lang.String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
Modifier and Type | Method and Description |
---|---|
static OutputConditionFactory |
OutputConditionFactoryFactory.createCondition(OutputLimitSpec outputLimitSpec,
StatementContext statementContext,
boolean isGrouped,
boolean isWithHavingClause,
boolean isStartConditionOnCreation,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
static OutputConditionPolledFactory |
OutputConditionPolledFactoryFactory.createConditionFactory(OutputLimitSpec outputLimitSpec,
StatementContext statementContext) |
Constructor and Description |
---|
OutputConditionFirstFactory(OutputLimitSpec outputLimitSpec,
StatementContext statementContext,
boolean isGrouped,
boolean isWithHavingClause,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |