performing a join like operation on a two streams is certainly possible, as is filtering or mapping a stream.
I have a lib for some of this stuff https://github.com/dominictarr/event-stream max, min, sort, count etc, unfortunately cannot return a correct answer until they have received the end event, so using the Stream interface in that case looses the purpose of streams. although, if you are interested in streaming aggregates that periodically emit the most uptodate aggregate (rather than a single final answer) I also played around with making a realtime map reduce lib. I havn't used it for anything, but it has tests. https://github.com/dominictarr/reducer It can also deal with the case where a row is updated and that has changed the total. I've implemented several ways of handling updates. On Wed, Apr 25, 2012 at 2:10 AM, manimal45 <moshir.mik...@gmail.com> wrote: > It's all good and creative, nonetheless, does anyone outthere has > looked at twitter's storm. > It's closer to what I've got in mind (see first post) and goes a > little step further with algorithmics: > - joins > - aggregates > - ... > > For instance joining two json streams coming from two different > databases can be achieved simply by bolts in storm (which i don't know > and don't want to use at all because configuration seems not that > simple !!). > > Most of existing module focus on parsing json chunks to ouptut json > rows. > I instead assume json is parsed (thanks to wonderful modules outhere) > and want to compose streams. > > Go and look at storm to get an idea of the use cases better than i > could explain myself. > > > On 24 avr, 14:43, Nuno Job <nunojobpi...@gmail.com> wrote: > > Roly you could have told me this existed :PP God damnit :) > > > > Stoked! > > > > Nuno > > > > > > > > > > > > > > > > On Tue, Apr 24, 2012 at 1:35 PM, Roly Fentanes <r...@markover.me> wrote: > > > in mind continously prints j > > -- > Job Board: http://jobs.nodejs.org/ > Posting guidelines: > https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines > You received this message because you are subscribed to the Google > Groups "nodejs" group. > To post to this group, send email to nodejs@googlegroups.com > To unsubscribe from this group, send email to > nodejs+unsubscr...@googlegroups.com > For more options, visit this group at > http://groups.google.com/group/nodejs?hl=en?hl=en > -- Job Board: http://jobs.nodejs.org/ Posting guidelines: https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines You received this message because you are subscribed to the Google Groups "nodejs" group. To post to this group, send email to nodejs@googlegroups.com To unsubscribe from this group, send email to nodejs+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/nodejs?hl=en?hl=en
