Hi, Recently while implementing a stats listener which is set on 2 different logical operators, specifically used to slow down an upstream operator using the stats from downstream partitions, I realize the code gets unwieldy.
A reason for this is that there is no effortless way of knowing which logical operator the stats belong to. BatchedOperatorStats contains operator id but that is assigned at the runtime (unknown at the time of writing code). I had created the following ticket to address this address this and would like to work on it. https://malhar.atlassian.net/browse/APEX-69 Thanks, Chandni
