diff options
| author | Adam Kocoloski <kocolosk@apache.org> | 2018-05-28 09:56:04 -0400 |
|---|---|---|
| committer | Adam Kocoloski <kocolosk@apache.org> | 2018-05-28 09:56:04 -0400 |
| commit | 02f9c010f536f84939b664aa361016d3f32a0cec (patch) | |
| tree | 1a85c5f32cb39d55e5336943f52da2a5ae3cc69a | |
| parent | ebf808d3e4e462f46fb0af7dd453bc10668bdb04 (diff) | |
| download | couchdb-02f9c010f536f84939b664aa361016d3f32a0cec.tar.gz | |
Squash 5d184152 to rebase COUCHDB-2971 work
commit 5d18415237e7a01e1ac401607f7fc36b671bf640
Author: Adam Kocoloski <kocolosk@apache.org>
Date: Thu Apr 28 15:12:44 2016 -0400
Add a finalize step after rereduce
Currently this is a noop for every reduce function except the HLL
cardinately estimator implemented in _distinct.
COUCHDB-2971
| -rw-r--r-- | src/fabric/src/fabric_view.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/fabric/src/fabric_view.erl b/src/fabric/src/fabric_view.erl index dd0fcfd8b..4d8d0e987 100644 --- a/src/fabric/src/fabric_view.erl +++ b/src/fabric/src/fabric_view.erl @@ -230,8 +230,9 @@ get_next_row(#collector{reducer = RedSrc} = St) when RedSrc =/= undefined -> end, Counters0, Records), Wrapped = [[V] || #view_row{value=V} <- Records], {ok, [Reduced]} = couch_query_servers:rereduce(Lang, [RedSrc], Wrapped), + {ok, [Finalized]} = couch_query_servers:finalize([Reduced]), NewSt = St#collector{keys=RestKeys, rows=NewRowDict, counters=Counters}, - {#view_row{key=Key, id=reduced, value=Reduced}, NewSt}; + {#view_row{key=Key, id=reduced, value=Finalized}, NewSt}; error -> get_next_row(St#collector{keys=RestKeys}) end; |