Re: Question about Flink Streaming

2015-03-24 Thread Matthias J. Sax
Hi Gyula, thank a lot. I still don't understand why setup() and open() can not be unified? I also don't know, what the difference between RuntimeContext and StreamTaskContext is (or to be more precise, why not using a single context class that unifies both)? About the renaming of Timestamp

Re: Question about Flink Streaming

2015-03-24 Thread Gyula Fóra
Hey Matthias, Let's see if I get these things for you :) 1) The difference between setup and open is that, setup to set things like collectors, runtimecontext and everything that will be used by the implemented invokable, and also by the rich functions. Open is called after setup, to actually

Re: Question about Flink Streaming

2015-03-24 Thread Gyula Fóra
The setup and open methods could be called together, but they do different tasks, and therefore I dont see any reason why they should be in a same method. This is a critical part of the code so better keep things clean and separate. The RuntimeContext refers to the operator while the TaskContext