Class: Rubadoop::MapReduce::StandardOut

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

Instance Method Summary collapse

Methods inherited from CollectCounters

#counters

Instance Method Details

#counter(group, counter, amount) ⇒ Object



66
67
68
69
# File 'lib/rubadoop/map_reduce/io.rb', line 66

def counter(group, counter, amount)
  super
  MapReduce.io_out.puts "Counter: #{group}.#{counter} +#{amount}"
end

#entry(value) ⇒ Object



76
77
78
# File 'lib/rubadoop/map_reduce/io.rb', line 76

def entry(value)
  MapReduce.io_out.puts "Entry: #{value}"
end

#error(message) ⇒ Object



79
80
81
# File 'lib/rubadoop/map_reduce/io.rb', line 79

def error(message)
  MapReduce.io_err.puts message
end

#map_entry(key, value) ⇒ Object



73
74
75
# File 'lib/rubadoop/map_reduce/io.rb', line 73

def map_entry(key, value)
  MapReduce.io_out.puts "MapEntry: #{key}\t#{value}"
end

#status(status) ⇒ Object



70
71
72
# File 'lib/rubadoop/map_reduce/io.rb', line 70

def status(status)
  MapReduce.io_out.puts "reporter:status:#{status}"
end