Package com.espertech.esper.common.internal.epl.join.strategy

Class ExecNodeQueryStrategy

java.lang.Object

com.espertech.esper.common.internal.epl.join.strategy.ExecNodeQueryStrategy

All Implemented Interfaces:

QueryStrategy

public class ExecNodeQueryStrategy
extends Object
implements QueryStrategy

Query strategy for building a join tuple set by using an execution node tree.

Constructor Summary

Constructors

Constructor	Description
ExecNodeQueryStrategy(int forStream, int numStreams, ExecNode execNode)	CTor.

Method Summary

Modifier and Type	Method	Description
protected ExecNode	getExecNode()	Returns execution node.
protected int	getForStream()	Return stream number this strategy is for.
protected int	getNumStreams()	Returns the total number of streams.
void	lookup(EventBean[] lookupEvents, Set<MultiKeyArrayOfKeys<EventBean>> joinSet, ExprEvaluatorContext exprEvaluatorContext)	Look up events returning tuples of joined events.

Methods inherited from class java.lang.Object

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

Constructor Details

ExecNodeQueryStrategy

public ExecNodeQueryStrategy(int forStream,
 int numStreams,
 ExecNode execNode)

CTor.

Parameters:

forStream - - stream the strategy is for

numStreams - - number of streams in total

execNode - - execution node for building join tuple set

Method Details

lookup

public void lookup(EventBean[] lookupEvents,
 Set<MultiKeyArrayOfKeys<EventBean>> joinSet,
 ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: QueryStrategy

Look up events returning tuples of joined events.

Specified by:

lookup in interface QueryStrategy

Parameters:

lookupEvents - - events to use to perform the join

joinSet - - result join tuples of events

exprEvaluatorContext - expression evaluation context

getForStream

protected int getForStream()

Return stream number this strategy is for.

Returns:

stream num

getNumStreams

protected int getNumStreams()

Returns the total number of streams.

Returns:

number of streams

getExecNode

protected ExecNode getExecNode()

Returns execution node.

Returns:

execution node