Hi. I'm recently read about reactive streams, and want to know some more about it.
In particular I was trying to use the 'Flow' methodology to replace some existing log-analysis software, which does things like page views, unique visitors and things like that in 5 minute blocks. It looks quite simple to create the flows, and the 'esper' example I found looks really close. but I have two questions. how does one deal with time. specifically how do I set up a periodic scheduler to tell the flow that it's time to emit results. (and ideally allow my service to set the time based on input records and not use system time, so I can do stuff like replaying logs) and secondly how do I scale these flows to work over multiple machines. Ideally I'd like to just hand a dozen machines to Akka and say 'go wild' and let it figure it all out, but failing that how can I allocate resources to a producer? Thanks Ian -- Ian Holsman [email protected] PH: + 61-3-9028 8133 / +1-(425) 998-7083 -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
