Kouhei Sutou
null+****@clear*****
Mon Jan 27 16:24:14 JST 2014
Kouhei Sutou 2014-01-27 16:24:14 +0900 (Mon, 27 Jan 2014) New Revision: b6993b2539508fae81bf2a27bb1c4739329a9b03 https://github.com/droonga/fluent-plugin-droonga/commit/b6993b2539508fae81bf2a27bb1c4739329a9b03 Message: Align Modified files: lib/droonga/distributor_plugin.rb Modified: lib/droonga/distributor_plugin.rb (+21 -21) =================================================================== --- lib/droonga/distributor_plugin.rb 2014-01-27 15:41:43 +0900 (1f24c41) +++ lib/droonga/distributor_plugin.rb 2014-01-27 16:24:14 +0900 (2b64be9) @@ -51,44 +51,44 @@ module Droonga def scatterer(message, key) { - "command"=> message["type"], - "dataset"=> message["dataset"], - "body"=> message["body"], - "key"=> key, - "type"=> "scatter", - "outputs"=>[], - "replica"=> "all", - "post"=> true + "command" => message["type"], + "dataset" => message["dataset"], + "body" => message["body"], + "key" => key, + "type" => "scatter", + "outputs" => [], + "replica" => "all", + "post" => true } end def broadcaster(message) { - "command"=> message["type"], - "dataset"=> message["dataset"], - "body"=> message["body"], - "type"=> "broadcast", - "outputs"=>[], - "replica"=> "all", - "post"=> true + "command" => message["type"], + "dataset" => message["dataset"], + "body" => message["body"], + "type" => "broadcast", + "outputs" => [], + "replica" => "all", + "post" => true } end def reducer(message) { - "type" => "reduce", - "body" => {}, - "inputs" => [], + "type" => "reduce", + "body" => {}, + "inputs" => [], "outputs" => [], } end def gatherer(message) { - "type" => "gather", - "body" => {}, + "type" => "gather", + "body" => {}, "inputs" => [], - "post" => true, + "post" => true, } end end -------------- next part -------------- HTML����������������������������...Download