Contents

module JRubyOnHadoop
  JAVA_MAIN_CLASS = 'org.apache.hadoop.ruby.JRubyJobRunner' 

  class Client
    def initialize(argv=[])
      @init_script = argv[0] || 'mapred.rb'
      @args = argv[1..argv.size-1].join(" ") if argv.size > 0
    end

    def run
      exec cmd
    end

    def cmd
      "hadoop jar #{main_jar_path} #{JAVA_MAIN_CLASS}" +
      " -libjars #{jruby_jar_paths} -files #{@init_script} #{@args}"
    end

    def main_jar_path
      JRubyOnHadoop.jar_path
    end

    def jruby_jar_paths
      [JRubyJars.core_jar_path, JRubyJars.stdlib_jar_path].join(',')
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jruby-on-hadoop-0.0.2	lib/jruby-on-hadoop/client.rb