Class: Skynet::MapreduceTest

Inherits:
Object
  • Object
show all
Includes:
SkynetDebugger
Defined in:
lib/skynet/mapreduce_test.rb

Class Method Summary collapse

Methods included from SkynetDebugger

#args_pp, #debug, #debug_header, #error, #fatal, included, #info, #log, #warn

Class Method Details

.map(datas) ⇒ Object 



5
6
7
8
9
10
11
12
 
# File 'lib/skynet/mapreduce_test.rb', line 5

def self.map(datas)
  results = {}
  datas.each do |data|
    results[data] ||= 0
    results[data] += 1
  end                 
  [results]      
end

.reduce(datas) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
 
# File 'lib/skynet/mapreduce_test.rb', line 14

def self.reduce(datas)
  results = {}
  datas.each do |hashes|
    hashes.each do |key,value|
      results[key] ||= 0
      results[key] += value
    end
  end
  results
end