Re: RichMapFunction in DataStream, how do I set the parameters received in open?

2016-09-12 Thread Luis Mariano Guerra
On Mon, Sep 12, 2016 at 8:35 PM, Chesnay Schepler wrote: > Hello, > > you cannot pass a configuration in the Steaming API. This way of > configuration is more of a relic from past times. > > The common way to pass configure a function is to pass the parameters > through the

Re: RichMapFunction in DataStream, how do I set the parameters received in open?

2016-09-12 Thread Chesnay Schepler
Hello, you cannot pass a configuration in the Steaming API. This way of configuration is more of a relic from past times. The common way to pass configure a function is to pass the parameters through the constructor and store the values in a field. Regards, Chesnay On 12.09.2016 18:27,

RichMapFunction in DataStream, how do I set the parameters received in open?

2016-09-12 Thread Luis Mariano Guerra
hi! I'm trying to pass Configuration parameters to a RichMapFunction in flink streaming and I can't find the way to do it I need to pass two strings to the MapFunction and I was getting a serialization error, so I tried RichMapFunction and open() but I can't find a way to set the the parameters I