Adding metrics to individual RichMapFunction implementation classes would give metrics information about that particular class.
As a pipeline consists of multiple such classes, how can we have metrics for the overall data pipeline?Are there any best practices for it? With regards
