Hi Piper,
the RichMapFunction's map function is called for every record you are
processing in your DataStream/DataSet. The RichMapFunction is the
definition of the map function you are applying to every record. Hence, it
is basically what you pass to the DataStream.map(MapFunction myMapFunction)
i
Hi
I have questions regarding making my own custom metrics.
When exactly is the class RichMapFunction’s map(value) method
called/invoked, and what “value” will be passed/expected as an argument to
this map(value) method?
Does the RichMapFunction’s map() method have any relation to the
transforma
