See if there is anything you can borrow from Akka Streaming API for Flink Streams: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala.html
The DSL looks good and perhaps might stimulate some ideas. -- View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Flink-Streaming-Scala-API-tp2972p2983.html Sent from the Apache Flink (Incubator) Mailing List archive. mailing list archive at Nabble.com.
