com.espertech.esper.epl.core

Class ResultSetProcessorUtil

java.lang.Object

com.espertech.esper.epl.core.ResultSetProcessorUtil

public class ResultSetProcessorUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorUtil()

Method Summary

Modifier and Type	Method and Description
static void	applyAggJoinResult(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents)
static void	applyAggViewResult(AggregationService aggregationService, ExprEvaluatorContext exprEvaluatorContext, EventBean[] newData, EventBean[] oldData, EventBean[] eventsPerStream)
static void	clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService, Viewable parent)
protected static EventBean[]	getSelectEventsHaving(SelectExprProcessor exprProcessor, EventBean[] events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext) Applies the select-clause to the given events returning the selected events.
protected static EventBean[]	getSelectEventsHavingWithOrderBy(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.
protected static EventBean[]	getSelectEventsNoHaving(SelectExprProcessor exprProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext) Applies the select-clause to the given events returning the selected events.
protected static EventBean[]	getSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext) Applies the select-clause to the given events returning the selected events.
protected static EventBean[]	getSelectJoinEventsHaving(SelectExprProcessor exprProcessor, Set<MultiKey<EventBean>> events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext) Applies the select-clause to the given events returning the selected events.
protected static EventBean[]	getSelectJoinEventsHavingWithOrderBy(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.
protected static EventBean[]	getSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor, Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext) Applies the select-clause to the given events returning the selected events.
protected static EventBean[]	getSelectJoinEventsNoHavingWithOrderBy(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.
static ArrayDeque<EventBean>	iteratorToDeque(Iterator<EventBean> it)
protected static void	populateSelectEventsHaving(SelectExprProcessor exprProcessor, EventBean[] events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, List<EventBean> result, List<Object> optSortKeys, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectEventsNoHaving(SelectExprProcessor exprProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, Collection<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, Collection<EventBean> result, List<Object> sortKeys, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor, Set<MultiKey<EventBean>> events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, Set<MultiKey<EventBean>> events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, List<EventBean> result, List<Object> sortKeys, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor, Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
protected static void	populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, List<EventBean> result, List<Object> optSortKeys, ExprEvaluatorContext exprEvaluatorContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultSetProcessorUtil

public ResultSetProcessorUtil()

Method Detail

applyAggViewResult

public static void applyAggViewResult(AggregationService aggregationService,
                                      ExprEvaluatorContext exprEvaluatorContext,
                                      EventBean[] newData,
                                      EventBean[] oldData,
                                      EventBean[] eventsPerStream)

applyAggJoinResult

public static void applyAggJoinResult(AggregationService aggregationService,
                                      ExprEvaluatorContext exprEvaluatorContext,
                                      Set<MultiKey<EventBean>> newEvents,
                                      Set<MultiKey<EventBean>> oldEvents)

getSelectEventsNoHaving

protected static EventBean[] getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
                                                     EventBean[] events,
                                                     boolean isNewData,
                                                     boolean isSynthesize,
                                                     ExprEvaluatorContext exprEvaluatorContext)

Applies the select-clause to the given events returning the selected events. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Parameters:

exprProcessor - - processes each input event and returns output event

events - - input events

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectEventsNoHavingWithOrderBy

protected static EventBean[] getSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
                                                                OrderByProcessor orderByProcessor,
                                                                EventBean[] events,
                                                                boolean isNewData,
                                                                boolean isSynthesize,
                                                                ExprEvaluatorContext exprEvaluatorContext)

Applies the select-clause to the given events returning the selected events. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Parameters:

exprProcessor - - processes each input event and returns output event

orderByProcessor - - orders the outgoing events according to the order-by clause

events - - input events

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectEventsHavingWithOrderBy

protected static EventBean[] getSelectEventsHavingWithOrderBy(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. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Also applies a having clause.

Parameters:

exprProcessor - - processes each input event and returns output event

orderByProcessor - - for sorting output events according to the order-by clause

events - - input events

havingNode - - supplies the having-clause expression

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectEventsHaving

protected static EventBean[] getSelectEventsHaving(SelectExprProcessor exprProcessor,
                                                   EventBean[] events,
                                                   ExprEvaluator havingNode,
                                                   boolean isNewData,
                                                   boolean isSynthesize,
                                                   ExprEvaluatorContext exprEvaluatorContext)

Applies the select-clause to the given events returning the selected events. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Also applies a having clause.

Parameters:

exprProcessor - - processes each input event and returns output event

events - - input events

havingNode - - supplies the having-clause expression

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectJoinEventsNoHavingWithOrderBy

protected static EventBean[] getSelectJoinEventsNoHavingWithOrderBy(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. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Parameters:

exprProcessor - - processes each input event and returns output event

orderByProcessor - - for sorting output events according to the order-by clause

events - - input events

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectJoinEventsNoHaving

protected static EventBean[] getSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
                                                         Set<MultiKey<EventBean>> events,
                                                         boolean isNewData,
                                                         boolean isSynthesize,
                                                         ExprEvaluatorContext exprEvaluatorContext)

Applies the select-clause to the given events returning the selected events. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Parameters:

exprProcessor - - processes each input event and returns output event

events - - input events

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectJoinEventsHaving

protected static EventBean[] getSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
                                                       Set<MultiKey<EventBean>> events,
                                                       ExprEvaluator havingNode,
                                                       boolean isNewData,
                                                       boolean isSynthesize,
                                                       ExprEvaluatorContext exprEvaluatorContext)

Applies the select-clause to the given events returning the selected events. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Also applies a having clause.

Parameters:

exprProcessor - - processes each input event and returns output event

events - - input events

havingNode - - supplies the having-clause expression

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

getSelectJoinEventsHavingWithOrderBy

protected static EventBean[] getSelectJoinEventsHavingWithOrderBy(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. The number of events stays the same, i.e. this method does not filter it just transforms the result set.

Also applies a having clause.

Parameters:

exprProcessor - - processes each input event and returns output event

orderByProcessor - - for sorting output events according to the order-by clause

events - - input events

havingNode - - supplies the having-clause expression

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

exprEvaluatorContext - context for expression evalauation

Returns:

output events, one for each input event

populateSelectEventsNoHaving

protected static void populateSelectEventsNoHaving(SelectExprProcessor exprProcessor,
                                                   EventBean[] events,
                                                   boolean isNewData,
                                                   boolean isSynthesize,
                                                   Collection<EventBean> result,
                                                   ExprEvaluatorContext exprEvaluatorContext)

populateSelectEventsNoHavingWithOrderBy

protected static void populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
                                                              OrderByProcessor orderByProcessor,
                                                              EventBean[] events,
                                                              boolean isNewData,
                                                              boolean isSynthesize,
                                                              Collection<EventBean> result,
                                                              List<Object> sortKeys,
                                                              ExprEvaluatorContext exprEvaluatorContext)

populateSelectEventsHaving

protected static void populateSelectEventsHaving(SelectExprProcessor exprProcessor,
                                                 EventBean[] events,
                                                 ExprEvaluator havingNode,
                                                 boolean isNewData,
                                                 boolean isSynthesize,
                                                 List<EventBean> result,
                                                 ExprEvaluatorContext exprEvaluatorContext)

populateSelectEventsHavingWithOrderBy

protected static void populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
                                                            OrderByProcessor orderByProcessor,
                                                            EventBean[] events,
                                                            ExprEvaluator havingNode,
                                                            boolean isNewData,
                                                            boolean isSynthesize,
                                                            List<EventBean> result,
                                                            List<Object> optSortKeys,
                                                            ExprEvaluatorContext exprEvaluatorContext)

populateSelectJoinEventsHaving

protected static void populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
                                                     Set<MultiKey<EventBean>> events,
                                                     ExprEvaluator havingNode,
                                                     boolean isNewData,
                                                     boolean isSynthesize,
                                                     List<EventBean> result,
                                                     ExprEvaluatorContext exprEvaluatorContext)

populateSelectJoinEventsHavingWithOrderBy

protected static void populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
                                                                OrderByProcessor orderByProcessor,
                                                                Set<MultiKey<EventBean>> events,
                                                                ExprEvaluator havingNode,
                                                                boolean isNewData,
                                                                boolean isSynthesize,
                                                                List<EventBean> result,
                                                                List<Object> sortKeys,
                                                                ExprEvaluatorContext exprEvaluatorContext)

populateSelectJoinEventsNoHaving

protected static void populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
                                                       Set<MultiKey<EventBean>> events,
                                                       boolean isNewData,
                                                       boolean isSynthesize,
                                                       List<EventBean> result,
                                                       ExprEvaluatorContext exprEvaluatorContext)

populateSelectJoinEventsNoHavingWithOrderBy

protected static void populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
                                                                  OrderByProcessor orderByProcessor,
                                                                  Set<MultiKey<EventBean>> events,
                                                                  boolean isNewData,
                                                                  boolean isSynthesize,
                                                                  List<EventBean> result,
                                                                  List<Object> optSortKeys,
                                                                  ExprEvaluatorContext exprEvaluatorContext)

clearAndAggregateUngrouped

public static void clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext,
                                              AggregationService aggregationService,
                                              Viewable parent)

iteratorToDeque

public static ArrayDeque<EventBean> iteratorToDeque(Iterator<EventBean> it)