com.espertech.esper.epl.join
Class JoinSetComposerStreamToWinImpl

java.lang.Object
  extended by com.espertech.esper.epl.join.JoinSetComposerStreamToWinImpl
All Implemented Interfaces:
JoinSetComposer

public class JoinSetComposerStreamToWinImpl
extends Object
implements JoinSetComposer

Implements the function to determine a join result for a unidirectional stream-to-window joins, in which a single stream's events are every only evaluated using a query strategy.


Constructor Summary
JoinSetComposerStreamToWinImpl(EventTable[][] repositories, int streamNumber, QueryStrategy queryStrategy)
          Ctor.
 
Method Summary
 void destroy()
          Destroy stateful index tables, if any.
 void init(EventBean[][] eventsPerStream)
          Provides initialization events per stream to composer to populate join indexes, if required
 UniformPair<Set<MultiKey<EventBean>>> join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream)
          Return join tuple result set from new data and old data for each stream.
 Set<MultiKey<EventBean>> staticJoin()
          For use in iteration over join statements, this must build a join tuple result set from all events in indexes, executing query strategies for each.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JoinSetComposerStreamToWinImpl

public JoinSetComposerStreamToWinImpl(EventTable[][] repositories,
                                      int streamNumber,
                                      QueryStrategy queryStrategy)
Ctor.

Parameters:
repositories - - for each stream an array of (indexed/unindexed) tables for lookup.
streamNumber - is the undirectional stream
queryStrategy - is the lookup query strategy for the stream
Method Detail

init

public void init(EventBean[][] eventsPerStream)
Description copied from interface: JoinSetComposer
Provides initialization events per stream to composer to populate join indexes, if required

Specified by:
init in interface JoinSetComposer
Parameters:
eventsPerStream - is an array of events for each stream, with null elements to indicate no events for a stream

destroy

public void destroy()
Description copied from interface: JoinSetComposer
Destroy stateful index tables, if any.

Specified by:
destroy in interface JoinSetComposer

join

public UniformPair<Set<MultiKey<EventBean>>> join(EventBean[][] newDataPerStream,
                                                  EventBean[][] oldDataPerStream)
Description copied from interface: JoinSetComposer
Return join tuple result set from new data and old data for each stream.

Specified by:
join in interface JoinSetComposer
Parameters:
newDataPerStream - - for each stream the event array (can be null).
oldDataPerStream - - for each stream the event array (can be null).
Returns:
join tuples

staticJoin

public Set<MultiKey<EventBean>> staticJoin()
Description copied from interface: JoinSetComposer
For use in iteration over join statements, this must build a join tuple result set from all events in indexes, executing query strategies for each.

Specified by:
staticJoin in interface JoinSetComposer
Returns:
static join result

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