Package | Description |
---|---|
com.espertech.esper.common.internal.epl.resultset.core | |
com.espertech.esper.common.internal.epl.resultset.order |
Order-by and row-limit processors
|
com.espertech.esper.common.internal.epl.resultset.rowpergrouprollup |
Result set processor for Rollup
|
Modifier and Type | Method and Description |
---|---|
static UniformPair<EventBean[]> |
ResultSetProcessorUtil.finalizeOutputMaySortMayRStream(List<EventBean> newEvents,
List<Object> newEventsSortKey,
List<EventBean> oldEvents,
List<Object> oldEventsSortKey,
boolean selectRStream,
OrderByProcessor orderByProcessor,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectEventsNoHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHavingWithOrderBy(AggregationService aggregationService,
SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
ResultSetProcessor |
ResultSetProcessorFactory.instantiate(OrderByProcessor orderByProcessor,
AggregationService aggregationService,
AgentInstanceContext agentInstanceContext) |
static ArrayEventIterator |
ResultSetProcessorUtil.orderOutgoingGetIterator(List<EventBean> outgoingEvents,
List<Object> orderKeys,
OrderByProcessor orderByProcessor,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static EventBean[] |
ResultSetProcessorUtil.outputFromCountMaySort(int count,
EventBean[] events,
Object[] keys,
EventBean[][] currentGenerators,
boolean isNewData,
OrderByProcessor orderByProcessor,
AgentInstanceContext agentInstanceContext,
AggregationService aggregationService)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static void |
ResultSetProcessorUtil.populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> result,
List<Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Method and Description |
---|---|
OrderByProcessor |
OrderByProcessorFactory.instantiate(AgentInstanceContext agentInstanceContext) |
Modifier and Type | Method and Description |
---|---|
static EventsAndSortKeysPair |
ResultSetProcessorRowPerGroupRollupUtil.getOldEventsSortKeys(int oldEventCount,
EventArrayAndSortKeyArray rstreamEventSortArrayBuf,
OrderByProcessor orderByProcessor,
AggregationGroupByRollupDesc rollupDesc) |
Copyright © 2005–2018. All rights reserved.