Re: Configuring a RichFunction on a DataStream

2016-04-28 Thread Fabian Hueske
Hi Robert, Function configuration via a Configuration object and the open method is an artifact from the past. The recommended way is to configure the function object via the constructor. Flink serializes the function object and ships them to the workers for execution. So the state of a function i

Configuring a RichFunction on a DataStream

2016-04-28 Thread Robert Schmidtke
Hi everyone, I noticed that in the DataSet API, there is the .withParameters function that allows passing values to a RichFunction's open method. I was wondering whether a similar approach can be used to the same thing in a DataStream. Right now I'm getting the parameters via getRuntimeContext, bu