This is an automated email from the ASF dual-hosted git repository. jkff pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 817cf97 Merge pull request #4735 from angoenka/change_default_thread add bd9c6aa `extractOutput()` ended up resetting underlying aggregation. This is due to use of `extractOrderedList()` which removes all the elements from the heap. `extractOrderedList()` is costly and is not required either. `extractOutput()` does not mutate now and is cheaper too. add 2cde00b review comments. add 8bc6f23 Use TreeSet in place of PriorityQueue. add c24aebd update checksWithMultipleMerges() to check for multiple merges by keeping track of number of merges in accumulator. new 0be4c54 Merge pull request #4688: [BEAM-3705] ApproximateUnique resets its accumulator with each firing. The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/beam/sdk/testing/CombineFnTester.java | 1 + .../beam/sdk/transforms/ApproximateUnique.java | 85 +++++++++------------- .../beam/sdk/testing/CombineFnTesterTest.java | 33 +++++---- .../beam/sdk/transforms/ApproximateUniqueTest.java | 60 +++++++++++++++ 4 files changed, 112 insertions(+), 67 deletions(-) -- To stop receiving notification emails like this one, please contact j...@apache.org.