On Mon, Sep 12, 2016 at 8:35 PM, Chesnay Schepler <ches...@apache.org>
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 constructor and store the values in a field.
>
thanks!
I tried that before but I was having problems with a field of the class not
being serializable.
for anyone that may have this problem, mark the field as transient and
initialize it on first use :)
private transient Field fieldAccessor;
...
@Override
public Tuple2<String, Integer> map(Object obj) throws Exception
{
if (fieldAccessor == null) {
Class<?> cls = Class.forName(className);
fieldAccessor = cls.getDeclaredField(fieldName);
}
...
}
>
> Regards,
> Chesnay
>
>
> 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?
>
>
>
