YUKI Hiroshi
null+****@clear*****
Wed Jan 29 16:39:50 JST 2014
YUKI Hiroshi 2014-01-29 16:39:50 +0900 (Wed, 29 Jan 2014) New Revision: 77bf48c19d227ac9f8027de833c32e7cdc2240d5 https://github.com/droonga/fluent-plugin-droonga/commit/77bf48c19d227ac9f8027de833c32e7cdc2240d5 Message: Reduce errors separately Modified files: lib/droonga/plugin/distributor/distributed_search_planner.rb Modified: lib/droonga/plugin/distributor/distributed_search_planner.rb (+17 -8) =================================================================== --- lib/droonga/plugin/distributor/distributed_search_planner.rb 2014-01-29 15:03:38 +0900 (a8e1466) +++ lib/droonga/plugin/distributor/distributed_search_planner.rb 2014-01-29 16:39:50 +0900 (0ca9c4e) @@ -44,6 +44,21 @@ module Droonga 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 @@ module Droonga 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 -------------- next part -------------- HTML����������������������������...Download