!
Regards,
Isabelle
De : Fabian Hueske [mailto:fhue...@gmail.com]
Envoyé : jeudi 31 mai 2018 09:34
À : Robin, Isabelle
Cc : user@flink.apache.org; Nejjar, Driss
Objet : Re: Use element of the DataStream in parameter of RichMapFunction (open
function not called)
Hi Isabelle,
Welcome to the Flink user
Hello,
I'm working with Flink 1.4.2 (Scala API) and I'm having some trouble with my
custom RichMapFunction as I want the element in my Datastream to also be used
for a parameter of this custom class. My RichMapFunction is a simple counter
based on a MapState
Let's say I have those classes
-
