measuring time taken in map, reduceByKey, filter, flatMap

[Josh J]

Hi,

I have a stream pipeline which invokes map, reduceByKey, filter, and
flatMap. How can I measure the time taken in each stage?

Thanks,
Josh