On 06/08/2020 13:20, Manish G wrote:
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