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 transformation map() method, or are they completely different? Once defined, how do I put the custom metric onto a specific source, specific operator, and onto a specific sink in my job’s DAG? Thank you, Piper
