Package | Description |
---|---|
com.espertech.esper.epl.core.resultset.agggrouped |
Result set processor for Aggregated and Grouped
|
com.espertech.esper.epl.core.resultset.core |
Result set processor Core classes
|
com.espertech.esper.epl.core.resultset.grouped |
Result set processor utility classes for general grouped-aggregation
|
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 |
---|---|
OutputConditionPolledFactory |
ResultSetProcessorAggregateGroupedForge.getOptionalOutputFirstConditionFactory() |
OutputConditionPolledFactory |
ResultSetProcessorAggregateGroupedFactory.getOptionalOutputFirstConditionFactory() |
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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelperImpl.getOrAllocate(java.lang.Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory factory) |
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelper.getOrAllocate(java.lang.Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolledFactory |
ResultSetProcessorRowPerGroupForge.getOptionalOutputFirstConditionFactory() |
OutputConditionPolledFactory |
ResultSetProcessorRowPerGroupFactory.getOptionalOutputFirstConditionFactory() |
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 |
---|---|
OutputConditionPolledFactory |
ResultSetProcessorRowPerGroupRollupForge.getOptionalOutputFirstConditionFactory() |
OutputConditionPolledFactory |
ResultSetProcessorRowPerGroupRollupFactory.getOptionalOutputFirstConditionFactory() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Class and Description |
---|---|
class |
OutputConditionPolledCountFactory
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 |
OutputConditionPolledCrontabFactory
Output condition handling crontab-at schedule output.
|
class |
OutputConditionPolledExpressionFactory
Output condition for output rate limiting that handles when-then expressions for controlling output.
|
class |
OutputConditionPolledTimeFactory |
Modifier and Type | Method and Description |
---|---|
static OutputConditionPolledFactory |
OutputConditionPolledFactoryFactory.createConditionFactory(OutputLimitSpec outputLimitSpec,
StatementContext statementContext) |