net.esper.eql.join
Class ExecNodeQueryStrategy

java.lang.Object
  extended by net.esper.eql.join.ExecNodeQueryStrategy
All Implemented Interfaces:
QueryStrategy

public class ExecNodeQueryStrategy
extends java.lang.Object
implements QueryStrategy

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


Constructor Summary
ExecNodeQueryStrategy(int forStream, int numStreams, ExecNode execNode)
          CTor.
 
Method Summary
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, java.util.Set<MultiKey<EventBean>> joinSet)
          Look up events return tuples of joined events.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

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 Detail

lookup

public void lookup(EventBean[] lookupEvents,
                   java.util.Set<MultiKey<EventBean>> joinSet)
Description copied from interface: QueryStrategy
Look up events return 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

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