com.espertech.esper.epl.join.exec.composite
Class CompositeIndexQueryRange

java.lang.Object
  com.espertech.esper.epl.join.exec.composite.CompositeIndexQueryRange

All Implemented Interfaces:

CompositeIndexQuery

public class CompositeIndexQueryRange
extends java.lang.Object
implements CompositeIndexQuery

Constructor Summary

CompositeIndexQueryRange(boolean isNWOnTrigger, int lookupStream, int numStreams, SubordPropRangeKey subqRangeKey, java.lang.Class coercionType, java.util.List<java.lang.String> expressionTexts)

Method Summary

void	add(EventBean[] eventsPerStream, java.util.Map parent, java.util.Collection<EventBean> result)
void	add(EventBean theEvent, java.util.Map parent, java.util.Set<EventBean> result)
java.util.Collection<EventBean>	get(EventBean[] eventsPerStream, java.util.Map parent, ExprEvaluatorContext context)
java.util.Set<EventBean>	get(EventBean theEvent, java.util.Map parent, ExprEvaluatorContext context)
java.util.Collection<EventBean>	getCollectKeys(EventBean[] eventsPerStream, java.util.Map parent, ExprEvaluatorContext context, java.util.ArrayList<java.lang.Object> keys)
java.util.Set<EventBean>	getCollectKeys(EventBean theEvent, java.util.Map parent, ExprEvaluatorContext context, java.util.ArrayList<java.lang.Object> keys)
protected static java.util.Collection<EventBean>	handle(EventBean[] eventsPerStream, java.util.SortedMap sortedMapOne, java.util.SortedMap sortedMapTwo, java.util.Collection<EventBean> result, CompositeIndexQuery next)
protected static java.util.Set<EventBean>	handle(EventBean theEvent, java.util.SortedMap sortedMapOne, java.util.SortedMap sortedMapTwo, java.util.Set<EventBean> result, CompositeIndexQuery next)
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,
                                SubordPropRangeKey subqRangeKey,
                                java.lang.Class coercionType,
                                java.util.List<java.lang.String> expressionTexts)

Method Detail

add

public void add(EventBean theEvent,
                java.util.Map parent,
                java.util.Set<EventBean> result)

Specified by:

add in interface CompositeIndexQuery

add

public void add(EventBean[] eventsPerStream,
                java.util.Map parent,
                java.util.Collection<EventBean> result)

Specified by:

add in interface CompositeIndexQuery

get

public java.util.Set<EventBean> get(EventBean theEvent,
                                    java.util.Map parent,
                                    ExprEvaluatorContext context)

Specified by:

get in interface CompositeIndexQuery

get

public java.util.Collection<EventBean> get(EventBean[] eventsPerStream,
                                           java.util.Map parent,
                                           ExprEvaluatorContext context)

Specified by:

get in interface CompositeIndexQuery

getCollectKeys

public java.util.Set<EventBean> getCollectKeys(EventBean theEvent,
                                               java.util.Map parent,
                                               ExprEvaluatorContext context,
                                               java.util.ArrayList<java.lang.Object> keys)

Specified by:

getCollectKeys in interface CompositeIndexQuery

getCollectKeys

public java.util.Collection<EventBean> getCollectKeys(EventBean[] eventsPerStream,
                                                      java.util.Map parent,
                                                      ExprEvaluatorContext context,
                                                      java.util.ArrayList<java.lang.Object> keys)

Specified by:

getCollectKeys in interface CompositeIndexQuery

handle

protected static java.util.Set<EventBean> handle(EventBean theEvent,
                                                 java.util.SortedMap sortedMapOne,
                                                 java.util.SortedMap sortedMapTwo,
                                                 java.util.Set<EventBean> result,
                                                 CompositeIndexQuery next)

handle

protected static java.util.Collection<EventBean> handle(EventBean[] eventsPerStream,
                                                        java.util.SortedMap sortedMapOne,
                                                        java.util.SortedMap sortedMapTwo,
                                                        java.util.Collection<EventBean> result,
                                                        CompositeIndexQuery next)

setNext

public void setNext(CompositeIndexQuery next)

Specified by:

setNext in interface CompositeIndexQuery