Skip to content

Commit e614d01

Browse files
committed
minor tweaks, README correction
1 parent d65a050 commit e614d01

File tree

3 files changed

+8
-11
lines changed

3 files changed

+8
-11
lines changed

‎README‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,15 @@ By Blaine Cook.
22

33
http://romeda.org/blog/2007/04/mapreduce-in-36-lines-of-ruby.html
44

5-
If you want to add `dinject` (reduce) please do.
5+
If you want to add `dinject` (reduce) please do:
6+
http://github.com/defunkt/mapreducerb
67

78
In your shell:
89
$ sudo gem install RingyDingy
910
$ sudo gem install ruby2ruby
1011
$ ring_server &
11-
$ ruby mapreduce_runner &
12-
$ ruby mapreduce_runner &
12+
$ ruby mapreduce_runner.rb &
13+
$ ruby mapreduce_runner.rb &
1314

1415
In IRB:
1516
>> require 'mapreduce_enumerable'

‎mapreduce_enumerable.rb‎

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,12 @@
44

55
module Enumerable
66
def dmap(&block)
7-
self.each_with_index do |element,idx|
7+
each_with_index do |element,idx|
88
ring_server.write([:dmap, Process.pid, block.to_ruby, element, idx])
99
end
1010

1111
results = []
12-
while results.size < self.size
12+
while results.size < size
1313
result, idx = ring_server.take([:dmap, Process.pid, nil, nil]).last(2)
1414
results[idx] = result
1515
end
@@ -18,9 +18,6 @@ def dmap(&block)
1818
end
1919

2020
def ring_server
21-
return @ring_server if @ring_server
22-
23-
ringy_dingy = RingyDingy.new nil
24-
@ring_server = ringy_dingy.ring_server
21+
@ring_server ||= RingyDingy.new(nil).ring_server
2522
end
2623
end

���mapreduce_runner.rb‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,7 @@
22
require 'ruby2ruby'
33
require 'ringy_dingy'
44

5-
ringy_dingy = RingyDingy.new nil
6-
ring_server = ringy_dingy.ring_server
5+
ring_server = RingyDingy.new(nil).ring_server
76

87
loop do
98
pid, block, element, idx = ring_server.take([:dmap, nil, nil, nil, nil]).last(4)

0 commit comments

Comments
 (0)