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.
