Implement an automatic concept to reduce data from one stage of different threads
Suppose we use several threads each having a Count
stage. At the end of the analysis, we want to get the aggregated result of the threads' count
stages. For this situation, we need an annotation or a class that automatically reduce the data to a single result.