Hi Marino, What (measurable) benefit are you looking to achieve and how are you benchmarking it?
On Sun, Jan 3, 2016 at 11:23 AM, Marino Borra <[email protected]> wrote: > Hi Victor, thanks for your reply. > > > > Is possible to accumulate elements in parallel? Otherwise you can suggest > a point of extensions? > > > Il giorno sabato 2 gennaio 2016 19:38:54 UTC+1, √ ha scritto: >> >> Hi Marino, >> >> Yes, the grouping function (if by that you mean "grouped(100)") is not >> done in parallel (with respect to itself) >> >> On Sat, Jan 2, 2016 at 6:35 PM, Marino Borra <[email protected]> wrote: >> >>> Hi to all, >>> >>> >>> >>> I have a question. I want to create a flow that will process a large >>> size List with these steps: >>> >>> >>> >>> 1. Transform (concurrently) each elements >>> 2. Grouping (concurrently, one *grouped* per threads?) in Lists of >>> 1000 items >>> 3. With a function, simultaneously process the lists grouped >>> >>> I tried using the code below: >>> >>> Flow[String]. >>> mapAsyncUnordered(5) { >>> case audience:String => transform( audience, null ) >>> }. >>> grouped(100). >>> mapAsyncUnordered(4)( persist( _ ) ) ) >>> >>> But the grouping function is executed sequentially >>> >>> >>> Thanks to all for any suggestions >>> >>> Marino >>> >>> -- >>> >>>>>>>>>> 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 https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Cheers, >> √ >> > -- > >>>>>>>>>> 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Cheers, √ -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
