bin/mandy-local in mandy-0.4.3 vs bin/mandy-local in mandy-0.4.4
- old
+ new
@@ -45,10 +45,11 @@
out = nil
Mandy::Job.jobs.each_with_index do |job, i|
out = File.join(output_folder, "#{i+1}-#{job.name.downcase.gsub(/\W/, '-')}")
puts "Running #{job.name}..."
- `cat #{input} | mandy-map #{file} "#{job.name}" | sort | mandy-reduce #{file} "#{job.name}" > #{out}`
+ reduce_phase = job.reducer_defined? ? %(| sort | mandy-reduce #{file} "#{job.name}") : ''
+ `cat #{input} | mandy-map #{file} "#{job.name}" #{reduce_phase} > #{out}`
input = out
end
puts out
\ No newline at end of file