Module: Rubadoop::MapReduce::Utils

Included in:
Rubadoop::MapReduce
Defined in:
lib/rubadoop/map_reduce/utils.rb

Instance Method Summary collapse

Instance Method Details

#key_value_split(line) ⇒ Object 



4
5
6
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 4

def key_value_split(line)
  line.split("\t", 2)
end

#log_counter(group, counter, amount) ⇒ Object 



8
9
10
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 8

def log_counter(group, counter, amount)
  ::Rubadoop::MapReduce.out.counter(group, counter, amount)
end

#log_error(message) ⇒ Object 



16
17
18
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 16

def log_error(message)
  ::Rubadoop::MapReduce.out.error(message)
end

#log_status(status) ⇒ Object 



12
13
14
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 12

def log_status(status)
  ::Rubadoop::MapReduce.out.status(status)
end

#out_entry(value) ⇒ Object 



20
21
22
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 20

def out_entry(value)
  ::Rubadoop::MapReduce.out.entry(value)
end

#out_map_entry(key, value) ⇒ Object 



24
25
26
 
# File 'lib/rubadoop/map_reduce/utils.rb', line 24

def out_map_entry(key, value)
  ::Rubadoop::MapReduce.out.map_entry(key, value)
end