Package | Description |
---|---|
com.espertech.esper.common.internal.epl.output.polled | |
com.espertech.esper.common.internal.epl.resultset.core | |
com.espertech.esper.common.internal.epl.resultset.grouped | |
com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup |
Result set processor for Rollup
|
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 |
---|---|
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryDefault.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
Class[] groupKeyTypes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
Class[] groupKeyTypes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
Modifier and Type | Method and Description |
---|---|
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelperImpl.getOrAllocate(Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory factory) |
OutputConditionPolled |
ResultSetProcessorGroupedOutputFirstHelper.getOrAllocate(Object mk,
AgentInstanceContext agentInstanceContext,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorGroupedOutputFirstHelper[] |
ResultSetProcessorRowPerGroupRollupUtil.initializeOutputFirstHelpers(ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
AgentInstanceContext agentInstanceContext,
Class[] groupKeyTypes,
AggregationGroupByRollupDesc groupByRollupDesc,
OutputConditionPolledFactory outputConditionPolledFactory)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Copyright © 2005–2018. All rights reserved.