flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: RichMapFunction in DataStream, how do I set the parameters received in open?
Date Mon, 12 Sep 2016 18:35:51 GMT

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.


On 12.09.2016 18:27, Luis Mariano Guerra wrote:
> 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 get at open(Configuration params)
> withParameters seems to be only defined for batch from what I've seen.
> how do I make a serializable MapFunction that receives two strings as 
> configuration from outside its definition?

View raw message