Package | Description |
---|---|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.codegen |
Result set processor code generation classes
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
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.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Modifier and Type | Method and Description |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorAggregateGroupedForge.getOutputConditionType() |
ResultSetProcessorOutputConditionType |
ResultSetProcessorAggregateGroupedFactory.getOutputConditionType() |
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) |
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorFactory |
ResultSetProcessorFactoryCompiler.allocate(ResultSetProcessorFactoryForge forge,
EventType resultEventType,
StatementContext stmtContext,
boolean isFireAndForget,
boolean join,
boolean hasOutputLimit,
ResultSetProcessorOutputConditionType outputConditionType,
boolean hasOutputLimitSnapshot,
SelectExprProcessorForge[] selectExprProcessorForge,
boolean rollup) |
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorOutputConditionType |
ResultSetProcessorOutputConditionType.getConditionType(OutputLimitLimitType displayLimit,
boolean isAggregated,
boolean hasOrderBy,
boolean hasOptHint,
boolean isGrouped) |
static ResultSetProcessorOutputConditionType |
ResultSetProcessorOutputConditionType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ResultSetProcessorOutputConditionType[] |
ResultSetProcessorOutputConditionType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorSimpleForge.getOutputConditionType() |
ResultSetProcessorOutputConditionType |
ResultSetProcessorSimpleFactory.getOutputConditionType() |
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 |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowForAllFactory.getOutputConditionType() |
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) |
Modifier and Type | Method and Description |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowPerEventFactory.getOutputConditionType() |
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 |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowPerGroupForge.getOutputConditionType() |
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowPerGroupFactory.getOutputConditionType() |
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 |
---|---|
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowPerGroupRollupForge.getOutputConditionType() |
ResultSetProcessorOutputConditionType |
ResultSetProcessorRowPerGroupRollupFactory.getOutputConditionType() |
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) |
Constructor and Description |
---|
OutputProcessViewConditionFactory(StatementContext statementContext,
OutputStrategyPostProcessFactory postProcessFactory,
boolean distinct,
ExprTimePeriod afterTimePeriod,
Integer afterConditionNumberOfEvents,
EventType resultEventType,
OutputConditionFactory outputConditionFactory,
int streamCount,
ResultSetProcessorOutputConditionType conditionType,
OutputLimitLimitType outputLimitLimitType,
boolean terminable,
boolean hasAfter,
boolean isUnaggregatedUngrouped,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |