diff options
author | Robert Newson <rnewson@apache.org> | 2020-07-04 22:57:46 +0100 |
---|---|---|
committer | Robert Newson <rnewson@apache.org> | 2020-07-04 22:57:46 +0100 |
commit | c4cb82d868924ae462c820545169b4eda6a93ec9 (patch) | |
tree | 6ce174e34e7eb00797792f3200fe4a962cd7c840 | |
parent | c19e0a14b5ab9b71c82e30e354a42fc55e28b4cd (diff) | |
download | couchdb-c4cb82d868924ae462c820545169b4eda6a93ec9.tar.gz |
make upper bound of interactive reduce match tree maximum
-rw-r--r-- | src/ebtree.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ebtree.erl b/src/ebtree.erl index cb048acca..de6012263 100644 --- a/src/ebtree.erl +++ b/src/ebtree.erl @@ -189,11 +189,11 @@ reduce(Db, #tree{} = Tree, StartKey, EndKey) -> end. -maybe_reduce(#tree{} = Tree, {MapAcc, ReduceAcc}) when length(MapAcc) > 100 -> +maybe_reduce(#tree{} = Tree, {MapAcc, ReduceAcc}) when length(MapAcc) > Tree#tree.max -> Reduction = reduce_values(Tree, MapAcc, false), maybe_reduce(Tree, {[], [Reduction | ReduceAcc]}); -maybe_reduce(#tree{} = Tree, {MapAcc, ReduceAcc}) when length(ReduceAcc) > 100 -> +maybe_reduce(#tree{} = Tree, {MapAcc, ReduceAcc}) when length(ReduceAcc) > Tree#tree.max -> Reduction = reduce_values(Tree, ReduceAcc, true), {MapAcc, [Reduction]}; |