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
[email protected].
