Method: MapRedus::Finalizer.perform
- Defined in:
- lib/mapredus/finalizer.rb
.perform(pid) ⇒ Object
23 24 25 26 27 28 29 30 31 |
# File 'lib/mapredus/finalizer.rb', line 23 def self.perform(pid) process = Process.open(pid) result = finalize(process) Master.finish_metrics(pid) result ensure Master.free_slave(pid) process.next_state end |