YUKI Hiroshi
null+****@clear*****
Mon Feb 3 11:37:39 JST 2014
YUKI Hiroshi 2014-02-03 11:37:39 +0900 (Mon, 03 Feb 2014) New Revision: 340c2c4f99198d693ca4ceddaf3c6e10ed8fe5ca https://github.com/droonga/fluent-plugin-droonga/commit/340c2c4f99198d693ca4ceddaf3c6e10ed8fe5ca Message: Define outputs correctly Modified files: lib/droonga/distributed_command_planner.rb lib/droonga/plugin/distributor/distributed_search_planner.rb Modified: lib/droonga/distributed_command_planner.rb (+2 -0) =================================================================== --- lib/droonga/distributed_command_planner.rb 2014-02-03 11:34:38 +0900 (bd069b7) +++ lib/droonga/distributed_command_planner.rb 2014-02-03 11:37:39 +0900 (c47332f) @@ -54,6 +54,7 @@ module Droonga "body" => body || @source_message["body"], "key" => @key, "type" => "scatter", + "outputs" => [], "replica" => "all", "post" => true } @@ -65,6 +66,7 @@ module Droonga "dataset" => @dataset || @source_message["dataset"], "body" => body || @source_message["body"], "type" => "broadcast", + "outputs" => [], "replica" => "random" } if options[:write] Modified: lib/droonga/plugin/distributor/distributed_search_planner.rb (+1 -0) =================================================================== --- lib/droonga/plugin/distributor/distributed_search_planner.rb 2014-02-03 11:34:38 +0900 (131867c) +++ lib/droonga/plugin/distributor/distributed_search_planner.rb 2014-02-03 11:37:39 +0900 (a2e60d2) @@ -85,6 +85,7 @@ module Droonga def reduce(name, reducer, gatherer={}) @reducers << reducer_message("search_reduce", name, reducer) @gatherers << gatherer_message("search_gather", name, gatherer) + @outputs << output_name(name) end class QueryTransformer -------------- next part -------------- HTML����������������������������...Download