The Actor Publish looks like a good starting place! And the link <http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0-M2/java/stream-integrations.html#integrating-with-actors> JobManager looks like a good kickstart
Am Montag, 7. Dezember 2015 15:51:45 UTC+1 schrieb [email protected]: > > A good solution is create a source using ActorPublish to encapsulate the > query. > > Em segunda-feira, 7 de dezembro de 2015 11:47:16 UTC-3, [email protected] > escreveu: >> >> I am on the java stack so I can't use slick. >> >> 1) A sql table "data" gets filled up by some other proccess. >> >> 2) I do something like "select * from data order by time_stamp limit >> 1000" and use this as a stream source. >> >> 3) After the stream processing I delete the 1000 records and start at 1) >> again >> >> I am unsure how akka streams helps me with the stream source. >> Should I just provide a Iterator Interface over the sql.ResultSet? >> Or should I provide an Iterater for each "select" statement and use >> flatMap? >> >> >> >> >> -- >>>>>>>>>> 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.
