Re: Flink Streaming Scala API

Thanks for sharing. Gyula! - Henry On Sat, Dec 20, 2014 at 6:51 PM, Gyula Fóra wrote: > Hey guys, > > I am sure everyone is very busy with Christmas stuff, but if you are > getting bored try out the brand new Streaming Scala API. > > I have opened a PR for it here: > https://github.com/apache/in

Re: Need some help to implement the outer join operator

Hey Wilson, the MapFunction should act as a wrapper for the join function. create a class extending RichMapFunction, and pass the joinfunction via the constructor. then you delegate open/close calls to it, with the map function looking something like this: map(Tuple2<...> tuple) { return joinFunc

Re: Need some help to implement the outer join operator

Hi Fabian, It is very helpful of your response! But in order to make sure I understand correctly, I put my pseudo-code here first: class OuterJoinCoGroupFunction implements CoGroupFunction, Tuple2, Double>{ @Override public void coGroup(Iterable > iVals, Iterable > dVals, Collector out

Re: Flink Streaming Scala API

Also added a simple window-join example here , where you can check out some features :)

Re: Flink Streaming Scala API

Amazing, I'll try it out over the holidays! Am 21.12.2014 03:53 schrieb "Gyula Fóra" : > Hey guys, > > I am sure everyone is very busy with Christmas stuff, but if you are > getting bored try out the brand new Streaming Scala API. > > I have opened a PR for it here: > https://github.com/apache/inc