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.

Reply via email to