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.
 Set<MultiKey<EventBean>> staticJoin()
          A static join is for use with iterating over join statements.
 
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

staticJoin

public Set<MultiKey<EventBean>> staticJoin()
Description copied from interface: JoinExecutionStrategy
A static join is for use with iterating over join statements.

Specified by:
staticJoin in interface JoinExecutionStrategy
Returns:
set of rows, each row with two or more events, one for each stream

© 2007 EsperTech Inc.
All rights reserved.
Visit us at espertech.com