Reduce errors separately

droonga · Jan 29, 2014 · 77bf48c · 77bf48c
1 parent 9f54fb0
commit 77bf48c
Showing 1 changed file with 17 additions and 8 deletions.
diff --git a/lib/droonga/plugin/distributor/distributed_search_planner.rb b/lib/droonga/plugin/distributor/distributed_search_planner.rb
@@ -44,6 +44,21 @@ def build_messages
         transform_query(input_name, query)
       end
 
+      errors_reducer = {
+        "type" => "reduce",
+        "body" => {
+          "errors" => {
+            "errors_reduced" => {
+              "type" => "sum",
+              "limit" => -1,
+            },
+          },
+        },
+        "inputs" => ["errors"],
+        "outputs" => ["errors_reduced"],
+      }
+      @messages << errors_reducer
+
       gatherer = {
         "type" => "search_gather",
         "body" => @output_mappers.merge({
@@ -105,15 +120,9 @@ def transform_query(input_name, query)
           input_name => {
             output_name => transformer.reducers,
           },
-          "errors" => {
-            "errors_reduced" => {
-              "type" => "sum",
-              "limit" => -1,
-            },
-          },
         },
-        "inputs" => [input_name, "errors"], # XXX should be placed in the "body"?
-        "outputs" => [output_name, "errors_reduced"], # XXX should be placed in the "body"?
+        "inputs" => [input_name], # XXX should be placed in the "body"?
+        "outputs" => [output_name], # XXX should be placed in the "body"?
       }
       @messages << reducer