@@ -2,14 +2,15 @@ By Blaine Cook. http://romeda.org/blog/2007/04/mapreduce-in-36-lines-of-ruby.html -If you want to add `dinject` (reduce) please do. +If you want to add `dinject` (reduce) please do: +http://github.com/defunkt/mapreducerb In your shell: $ sudo gem install RingyDingy $ sudo gem install ruby2ruby $ ring_server & -$ ruby mapreduce_runner & -$ ruby mapreduce_runner & +$ ruby mapreduce_runner.rb & +$ ruby mapreduce_runner.rb & In IRB: >> require 'mapreduce_enumerable' README @@ -4,12 +4,12 @@ require 'ruby2ruby' module Enumerable def dmap(&block) - self.each_with_index do |element,idx| + each_with_index do |element,idx| ring_server.write([:dmap, Process.pid, block.to_ruby, element, idx]) end results = [] - while results.size < self.size + while results.size < size result, idx = ring_server.take([:dmap, Process.pid, nil, nil]).last(2) results[idx] = result end @@ -18,9 +18,6 @@ module Enumerable end def ring_server - return @ring_server if @ring_server - - ringy_dingy = RingyDingy.new nil - @ring_server = ringy_dingy.ring_server + @ring_server ||= RingyDingy.new(nil).ring_server end end mapreduce_enumerable.rb @@ -2,8 +2,7 @@ require 'rubygems' require 'ruby2ruby' require 'ringy_dingy' -ringy_dingy = RingyDingy.new nil -ring_server = ringy_dingy.ring_server +ring_server = RingyDingy.new(nil).ring_server loop do pid, block, element, idx = ring_server.take([:dmap, nil, nil, nil, nil]).last(4) mapreduce_runner.rb d65a05002920fdaceed754864fd92cbe37f8ebd3 Chris Wanstrath chris@ozmm.org http://github.com/defunkt/mapreducerb/commit/e614d01ff715d0c594ff22e844f53041e1e9d478 e614d01ff715d0c594ff22e844f53041e1e9d478 2008-04-26T01:32:01-07:00 2008-04-26T01:32:01-07:00 minor tweaks, README correction 8e062dfdc26fd7c10adcb1fd83e84f39dbaaae4a Chris Wanstrath chris@ozmm.org