Method: MapRedus::InputStream.perform

Defined in:
lib/mapredus/inputter.rb

.perform(pid, data_object) ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/mapredus/inputter.rb', line 21

def self.perform(pid, data_object)
  process = Process.open(pid)
  scan(*data_object) do |key, map_data|
    FileSystem.hset(ProcessInfo.input(pid), key, map_data)
    Master.enslave_map(process, key)
  end
ensure
  Master.free_slave(pid)
end