Hey, I have started developing the scala api for streaming on this git branch:
https://github.com/mbalassi/incubator-flink/tree/scala-api <https://github.com/mbalassi/incubator-flink/tree/scala-api> (you can try it out) I have done some refactoring in the java api to make it easier and already implemented some very basic functionality for the scala api (some simple sources and the map transformation). It will basically be copy pasting and modifying Aljoscha’s code (a lot of credit goes there) so there will be a lot of functionality added in the upcoming few days. Marton and Paris will also help in but everyone is welcome. Also does anyone know how to set max line length for the eclipse scala formatter? Gyula