Package | Description |
---|---|
com.espertech.esper.common.internal.epl.output.polled | |
com.espertech.esper.common.internal.epl.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.common.internal.epl.resultset.rowpergroup |
Result set processor for Fully-Aggregated and Grouped
|
com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup |
Result set processor for Rollup
|
Modifier and Type | Class and Description |
---|---|
class |
OutputConditionPolledCountFactoryForge
Output limit condition that is satisfied when either
the total number of new events arrived or the total number
of old events arrived is greater than a preset value.
|
class |
OutputConditionPolledCrontabFactoryForge
Output condition handling crontab-at schedule output.
|
class |
OutputConditionPolledExpressionFactoryForge
Output condition for output rate limiting that handles when-then expressions for controlling output.
|
class |
OutputConditionPolledTimeFactoryForge |
Modifier and Type | Method and Description |
---|---|
static OutputConditionPolledFactoryForge |
OutputConditionPolledFactoryFactory.createConditionFactory(OutputLimitSpec outputLimitSpec,
StatementRawInfo statementRawInfo,
StatementCompileTimeServices compileTimeServices) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolledFactoryForge |
ResultSetProcessorAggregateGroupedForge.getOptionalOutputFirstConditionFactory() |
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedForge(EventType resultEventType,
EventType[] typesPerStream,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
MultiKeyClassRef multiKeyClassRef) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolledFactoryForge |
ResultSetProcessorRowPerGroupForge.getOptionalOutputFirstConditionFactory() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupForge(EventType resultEventType,
EventType[] typesPerStream,
ExprNode[] groupKeyNodeExpressions,
ExprForge optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
MultiKeyClassRef multiKeyClassRef,
boolean unboundedProcessor) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolledFactoryForge |
ResultSetProcessorRowPerGroupRollupForge.getOptionalOutputFirstConditionFactory() |
Constructor and Description |
---|
ResultSetProcessorRowPerGroupRollupForge(EventType resultEventType,
EventType[] typesPerStream,
GroupByRollupPerLevelForge perLevelForges,
ExprNode[] groupKeyNodeExpressions,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDescForge groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorOutputConditionType outputConditionType,
OutputConditionPolledFactoryForge optionalOutputFirstConditionFactory,
EventType[] eventTypes,
MultiKeyClassRef multiKeyClassRef) |
Copyright © 2005–2021. All rights reserved.