Hi, I am planning to revisit the accumulation implementations and rewrite the getRetraction() method so that it behaves correctly. I understand that the concept of retraction is the upstream operator telling its downstream that the previous output is wrong and give it a new output. But it become confusing when it comes to actual implementation, how exactly should retraction be done in accumulations such as TopN and ReduceFn?
Thanks! Shunxin Lu
