YUKI Hiroshi
null+****@clear*****
Mon Feb 3 12:11:08 JST 2014
YUKI Hiroshi 2014-02-03 12:11:08 +0900 (Mon, 03 Feb 2014) New Revision: 2e46012ef1a522681106e6cb7cd2b2bb3a3bee4c https://github.com/droonga/fluent-plugin-droonga/commit/2e46012ef1a522681106e6cb7cd2b2bb3a3bee4c Message: Allow to define "key" of scattering after "scatter" is called Modified files: lib/droonga/distributed_command_planner.rb Modified: lib/droonga/distributed_command_planner.rb (+4 -1) =================================================================== --- lib/droonga/distributed_command_planner.rb 2014-02-03 11:39:33 +0900 (d7850b0) +++ lib/droonga/distributed_command_planner.rb 2014-02-03 12:11:08 +0900 (f027a23) @@ -52,7 +52,7 @@ module Droonga "command" => @source_message["type"], "dataset" => @dataset || @source_message["dataset"], "body" => body || @source_message["body"], - "key" => @key, + "key" => nil, "type" => "scatter", "outputs" => [], "replica" => "all", @@ -110,6 +110,9 @@ module Droonga def fixed_processor @processor["outputs"] = @outputs + if @processor["type"] == "scatter" + @processor["key"] = @key + end @processor end -------------- next part -------------- HTML����������������������������...Download