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

Class CompositeIndexQueryKeyed

java.lang.Object

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

All Implemented Interfaces:

CompositeIndexQuery

public class CompositeIndexQueryKeyed
extends Object
implements CompositeIndexQuery

Constructor Summary

Constructors

Constructor	Description
CompositeIndexQueryKeyed(boolean isNWOnTrigger, int lookupStream, int numStreams, ExprEvaluator hashGetter)

Method Summary

Modifier and Type	Method	Description
void	add(EventBean[] eventsPerStream, Map value, Collection<EventBean> result, CompositeIndexQueryResultPostProcessor postProcessor)
void	add(EventBean theEvent, Map value, 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)
void	setNext(CompositeIndexQuery next)

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeIndexQueryKeyed

public CompositeIndexQueryKeyed(boolean isNWOnTrigger,
 int lookupStream,
 int numStreams,
 ExprEvaluator hashGetter)

Method Details

setNext

public void setNext(CompositeIndexQuery next)

Specified by:

setNext in interface CompositeIndexQuery

get

public Set<EventBean> get(EventBean theEvent,
 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

get

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

Specified by:

get 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

add

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

Specified by:

add in interface CompositeIndexQuery

add

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

Specified by:

add in interface CompositeIndexQuery