|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface JoinSetComposer
Interface for populating a join tuple result set from new data and old data for each stream.
Method Summary | |
---|---|
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. |
Method Detail |
---|
void init(EventBean[][] eventsPerStream)
eventsPerStream
- is an array of events for each stream, with null elements to indicate no events for a streamUniformPair<Set<MultiKey<EventBean>>> join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream)
newDataPerStream
- - for each stream the event array (can be null).oldDataPerStream
- - for each stream the event array (can be null).
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |