Contents

#!/usr/bin/env ruby
require "rubygems"
require "mandy"

HadoopConfiguration.check_home_and_version

if ARGV.size==0
  puts "USAGE: mandy-reduce my_script.rb 'Job Name' [payload]"
  exit
end

def absolute_path(path)
  path =~ /^\// ? path : File.join(Dir.pwd, path)
end

if ARGV.size > 2
  payload = ARGV[2]
  Mandy::Packer.unpack(payload)
end

file   = absolute_path(ARGV[0])
job_name = ARGV[1]

require file

Mandy::Job.find_by_name(job_name).run_reduce

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
mandy-0.5.28	bin/mandy-reduce
mandy-0.5.27	bin/mandy-reduce
mandy-0.5.26	bin/mandy-reduce
mandy-0.5.25	bin/mandy-reduce
mandy-0.5.24	bin/mandy-reduce
mandy-0.5.23	bin/mandy-reduce
mandy-0.5.22	bin/mandy-reduce
mandy-0.5.21	bin/mandy-reduce
mandy-0.5.20	bin/mandy-reduce
mandy-0.5.19	bin/mandy-reduce
mandy-0.5.17	bin/mandy-reduce
mandy-0.5.14	bin/mandy-reduce
mandy-0.5.13	bin/mandy-reduce
mandy-0.5.11	bin/mandy-reduce
mandy-0.5.10	bin/mandy-reduce