Class: Hadupils::Runners::Hadoop

Inherits:
Base
  • Object
show all
Defined in:
lib/hadupils/runners.rb

Class Attribute Summary collapse

Attributes inherited from Base

#last_status, #last_stderr, #last_stdout, #params

Instance Method Summary collapse

Methods inherited from Base

#execute!, #initialize, #last_exitstatus, run, #wait!

Constructor Details

This class inherits a constructor from Hadupils::Runners::Base

Class Attribute Details

.base_runner ⇒ Object 



58
59
60
 
# File 'lib/hadupils/runners.rb', line 58

def self.base_runner
  @base_runner || ::File.join(ENV['HADOOP_HOME'], 'bin', 'hadoop')
end

Instance Method Details

#command ⇒ Object 



62
63
64
65
66
67
68
69
70
 
# File 'lib/hadupils/runners.rb', line 62

def command
  params.inject([self.class.base_runner]) do |result, param|
    if param.respond_to? :hadoop_opts
      result + param.hadoop_opts
    else
      result << param
    end
  end
end