com.espertech.esper.epl.core
Class ResultSetProcessorUtil

java.lang.Object
  extended by com.espertech.esper.epl.core.ResultSetProcessorUtil

public class ResultSetProcessorUtil
extends java.lang.Object


Constructor Summary
ResultSetProcessorUtil()
           
 
Method Summary
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, java.util.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, java.util.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, java.util.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, java.util.Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, ExprEvaluatorContext exprEvaluatorContext)
          Applies the select-clause to the given events returning the selected events.
protected static void populateSelectEventsHaving(SelectExprProcessor exprProcessor, EventBean[] events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, java.util.List<java.lang.Object> optSortKeys, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectEventsNoHaving(SelectExprProcessor exprProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, java.util.Collection<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, EventBean[] events, boolean isNewData, boolean isSynthesize, java.util.Collection<EventBean> result, java.util.List<java.lang.Object> sortKeys, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor, java.util.Set<MultiKey<EventBean>> events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, java.util.Set<MultiKey<EventBean>> events, ExprEvaluator havingNode, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, java.util.List<java.lang.Object> sortKeys, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor, java.util.Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, ExprEvaluatorContext exprEvaluatorContext)
           
protected static void populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor, OrderByProcessor orderByProcessor, java.util.Set<MultiKey<EventBean>> events, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> result, java.util.List<java.lang.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

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,
                                                                    java.util.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,
                                                         java.util.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,
                                                       java.util.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,
                                                                  java.util.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,
                                                   java.util.Collection<EventBean> result,
                                                   ExprEvaluatorContext exprEvaluatorContext)

populateSelectEventsNoHavingWithOrderBy

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

populateSelectEventsHaving

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

populateSelectEventsHavingWithOrderBy

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

populateSelectJoinEventsHaving

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

populateSelectJoinEventsHavingWithOrderBy

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

populateSelectJoinEventsNoHaving

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

populateSelectJoinEventsNoHavingWithOrderBy

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

© 2006-2014 EsperTech Inc.
All rights reserved.
Visit us at espertech.com