YUKI Hiroshi
null+****@clear*****
Thu Nov 28 15:50:27 JST 2013
YUKI Hiroshi 2013-11-28 15:50:27 +0900 (Thu, 28 Nov 2013) New Revision: 413e83ea3af594abe5eee057285ac771e8ca2fba https://github.com/droonga/fluent-plugin-droonga/commit/413e83ea3af594abe5eee057285ac771e8ca2fba Message: Define envelope attributes in the order defined in the specification (type, body, others) Modified files: lib/droonga/plugin/distributor/search.rb Modified: lib/droonga/plugin/distributor/search.rb (+5 -5) =================================================================== --- lib/droonga/plugin/distributor/search.rb 2013-11-28 15:42:19 +0900 (0b1c2eb) +++ lib/droonga/plugin/distributor/search.rb 2013-11-28 15:50:27 +0900 (de93a6a) @@ -69,14 +69,14 @@ module Droonga end reducer = { - "inputs" => [input_name], - "outputs" => [output_name], "type" => "reduce", "body" => { input_name => { output_name => elements, }, }, + "inputs" => [input_name], + "outputs" => [output_name], } message << reducer end @@ -88,12 +88,12 @@ module Droonga } message << gatherer searcher = { - "dataset" => envelope["dataset"] || request["dataset"], - "outputs" => input_names, "type" => "broadcast", "command" => "search", - "replica" => "random", + "dataset" => envelope["dataset"] || request["dataset"], "body" => request, + "outputs" => input_names, + "replica" => "random", } message.push(searcher) post(message) -------------- next part -------------- HTML����������������������������...Download