net.esper.eql.join
Class JoinExecutionStrategyImpl
java.lang.Object
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JoinExecutionStrategyImpl
public JoinExecutionStrategyImpl(JoinSetComposer composer,
JoinSetProcessor filter,
JoinSetProcessor indicator)
- Ctor.
- Parameters:
composer
- - determines join tuple setfilter
- - for filtering among tuplesindicator
- - for presenting the info to a view
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 streamoldDataPerStream
- - old events for each stream