net.esper.eql.join
Interface JoinSetComposer

All Known Implementing Classes:
JoinSetComposerImpl

public interface JoinSetComposer

Interface for populating a join tuple result set from new data and old data for each stream.


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.
 

Method Detail

init

void init(EventBean[][] eventsPerStream)
Provides initialization events per stream to composer to populate join indexes, if required

Parameters:
eventsPerStream - is an array of events for each stream, with null elements to indicate no events for a stream

join

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

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

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.

Returns:
static join result

destroy

void destroy()
Destroy stateful index tables, if any.


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