Class: Commands::PrintHiveVersionCommand

Inherits:
AbstractSSHCommand show all
Defined in:
lib/commands.rb

Constant Summary

Constants inherited from AbstractSSHCommand

AbstractSSHCommand::CLOSED_DOWN_STATES, AbstractSSHCommand::WAITING_OR_RUNNING_STATES

Instance Attribute Summary

Attributes inherited from AbstractSSHCommand

#dest, #hostname, #jobflow_detail, #jobflow_id, #key_pair_file, #no_wait

Attributes inherited from Command

#arg, #commands, #description, #logger, #name

Instance Method Summary collapse

Methods inherited from AbstractSSHCommand

#exec, #get_scp_opts, #get_ssh_opts, #initialize, #opts, #wait_for_jobflow

Methods inherited from Command

#get_field, #has_value, #have, #initialize, #option, #require, #require_single_jobflow, #resolve, #validate

Constructor Details

This class inherits a constructor from Commands::AbstractSSHCommand

Instance Method Details

#enact(client) ⇒ Object 



671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
 
# File 'lib/commands.rb', line 671

def enact(client)
  super(client)
  stdin, stdout, stderr = Open3.popen3("ssh -i #{key_pair_file} hadoop@#{hostname} '/home/hadoop/bin/hive -v'")
  version = stdout.readlines.join
  err = stderr.readlines.join
  if version.length > 0
    puts version
  elsif err =~ /Unrecognised option/ or err =~ /Error while determing Hive version/
    stdin, stdout, stderr = Open3.popen3("ssh -i #{key_pair_file} hadoop@#{hostname} 'ls -l /home/hadoop/bin/hive'")
    version = stdout.readlines.join
    version =~ /hive-(.*)\/bin\/hive/
    puts "Hive version " + $1
  else
    puts "Unable to determine Hive version"
  end
end