net.esper.eql.join
Class JoinExecutionStrategyImpl

java.lang.Object
  extended by net.esper.eql.join.JoinExecutionStrategyImpl
All Implemented Interfaces:
JoinExecutionStrategy

public class JoinExecutionStrategyImpl
extends Object
implements JoinExecutionStrategy

Join execution strategy based on a 3-step getSelectListEvents of composing a join set, filtering the join set and indicating.


Constructor Summary
JoinExecutionStrategyImpl(JoinSetComposer composer, JoinSetProcessor filter, JoinSetProcessor indicator)
          Ctor.
 
Method Summary
 void join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream)
          Execute join.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JoinExecutionStrategyImpl

public JoinExecutionStrategyImpl(JoinSetComposer composer,
                                 JoinSetProcessor filter,
                                 JoinSetProcessor indicator)
Ctor.

Parameters:
composer - - determines join tuple set
filter - - for filtering among tuples
indicator - - for presenting the info to a view
Method Detail

join

public void join(EventBean[][] newDataPerStream,
                 EventBean[][] oldDataPerStream)
Description copied from interface: JoinExecutionStrategy
Execute join. The first dimension in the 2-dim arrays is the stream that generated the events, and the second dimension is the actual events generated.

Specified by:
join in interface JoinExecutionStrategy
Parameters:
newDataPerStream - - new events for each stream
oldDataPerStream - - old events for each stream