Class: Rubadoop::MapReduce::CollectCounters

Inherits:
Object
  • Object
show all
Defined in:
lib/rubadoop/map_reduce/io.rb

Direct Known Subclasses

EmptyOut, RailsOut, StandardOut, TestOut

Instance Method Summary collapse

Instance Method Details

#counter(group, counter, amount) ⇒ Object 



35
36
37
38
39
40
41
42
 
# File 'lib/rubadoop/map_reduce/io.rb', line 35

def counter(group, counter, amount)
  c_group = counters[group] ||= Hash[]
  if c_group[counter]
    c_group[counter] += amount
  else
    c_group[counter] = amount
  end
end

#counters ⇒ Object 



31
32
33
 
# File 'lib/rubadoop/map_reduce/io.rb', line 31

def counters
  @counters ||= Hash[]
end