com.espertech.esper.common.internal.epl.join.exec.composite

Class CompositeIndexQueryRange

java.lang.Object

com.espertech.esper.common.internal.epl.join.exec.composite.CompositeIndexQueryRange

All Implemented Interfaces:

CompositeIndexQuery

public class CompositeIndexQueryRange
extends Object
implements CompositeIndexQuery

Constructor Summary

Constructors

Constructor and Description
CompositeIndexQueryRange(boolean isNWOnTrigger, int lookupStream, int numStreams, QueryGraphValueEntryRange rangeProp)

Method Summary

Modifier and Type	Method and Description
void	add(EventBean[] eventsPerStream, Map parent, Collection<EventBean> result, CompositeIndexQueryResultPostProcessor postProcessor)
void	add(EventBean theEvent, Map parent, Set<EventBean> result, CompositeIndexQueryResultPostProcessor postProcessor)
Collection<EventBean>	get(EventBean[] eventsPerStream, Map parent, ExprEvaluatorContext context, CompositeIndexQueryResultPostProcessor postProcessor)
Set<EventBean>	get(EventBean theEvent, Map parent, ExprEvaluatorContext context, CompositeIndexQueryResultPostProcessor postProcessor)
Collection<EventBean>	getCollectKeys(EventBean[] eventsPerStream, Map parent, ExprEvaluatorContext context, ArrayList<Object> keys, CompositeIndexQueryResultPostProcessor postProcessor)
Set<EventBean>	getCollectKeys(EventBean theEvent, Map parent, ExprEvaluatorContext context, ArrayList<Object> keys, CompositeIndexQueryResultPostProcessor postProcessor)
protected static Collection<EventBean>	handle(EventBean[] eventsPerStream, SortedMap sortedMapOne, SortedMap sortedMapTwo, Collection<EventBean> result, CompositeIndexQuery next, CompositeIndexQueryResultPostProcessor postProcessor)
protected static Set<EventBean>	handle(EventBean theEvent, SortedMap sortedMapOne, SortedMap sortedMapTwo, Set<EventBean> result, CompositeIndexQuery next, CompositeIndexQueryResultPostProcessor postProcessor)
void	setNext(CompositeIndexQuery next)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeIndexQueryRange

public CompositeIndexQueryRange(boolean isNWOnTrigger,
                                int lookupStream,
                                int numStreams,
                                QueryGraphValueEntryRange rangeProp)

Method Detail

add

public void add(EventBean theEvent,
                Map parent,
                Set<EventBean> result,
                CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

add in interface CompositeIndexQuery

add

public void add(EventBean[] eventsPerStream,
                Map parent,
                Collection<EventBean> result,
                CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

add in interface CompositeIndexQuery

get

public Set<EventBean> get(EventBean theEvent,
                          Map parent,
                          ExprEvaluatorContext context,
                          CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

get in interface CompositeIndexQuery

get

public Collection<EventBean> get(EventBean[] eventsPerStream,
                                 Map parent,
                                 ExprEvaluatorContext context,
                                 CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

get in interface CompositeIndexQuery

getCollectKeys

public Set<EventBean> getCollectKeys(EventBean theEvent,
                                     Map parent,
                                     ExprEvaluatorContext context,
                                     ArrayList<Object> keys,
                                     CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

getCollectKeys in interface CompositeIndexQuery

getCollectKeys

public Collection<EventBean> getCollectKeys(EventBean[] eventsPerStream,
                                            Map parent,
                                            ExprEvaluatorContext context,
                                            ArrayList<Object> keys,
                                            CompositeIndexQueryResultPostProcessor postProcessor)

Specified by:

getCollectKeys in interface CompositeIndexQuery

handle

protected static Set<EventBean> handle(EventBean theEvent,
                                       SortedMap sortedMapOne,
                                       SortedMap sortedMapTwo,
                                       Set<EventBean> result,
                                       CompositeIndexQuery next,
                                       CompositeIndexQueryResultPostProcessor postProcessor)

handle

protected static Collection<EventBean> handle(EventBean[] eventsPerStream,
                                              SortedMap sortedMapOne,
                                              SortedMap sortedMapTwo,
                                              Collection<EventBean> result,
                                              CompositeIndexQuery next,
                                              CompositeIndexQueryResultPostProcessor postProcessor)

setNext

public void setNext(CompositeIndexQuery next)

Specified by:

setNext in interface CompositeIndexQuery