class Fog::Compute::Hadoop::Real
Public Class Methods
new(options = {})
click to toggle source
# File lib/fog/hadoop/compute.rb, line 20 def initialize(options = {}) @compute_api_url = options[:hadoop_compute_api_url] || 'https://localhost:8088/' Fog.credentials[:@compute_api_url] = options[:hadoop_compute_api_url] @connection = Fog::Core::Connection.new(@compute_api_url) end
Public Instance Methods
get_app_stats()
click to toggle source
# File lib/fog/hadoop/requests/compute/get_app_stats.rb, line 5 def get_app_stats request( :expects => [200, 203], :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/appstatistics" ).body["appStatInfo"]["statItem"] end
get_app_stats_detail(options = {})
click to toggle source
# File lib/fog/hadoop/requests/compute/get_app_stats_detail.rb, line 5 def get_app_stats_detail(options = {}) request( :expects => [200, 203], :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/appstatistics?#{URI.encode_www_form(options)}" ).body["appStatInfo"]["statItem"] end
get_info()
click to toggle source
# File lib/fog/hadoop/requests/compute/get_info.rb, line 5 def get_info request( :expects => [200, 203], :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/info" ).body["clusterInfo"] end
get_metrics()
click to toggle source
# File lib/fog/hadoop/requests/compute/get_metrics.rb, line 5 def get_metrics request( :expects => 200, :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/metrics" ).body["clusterMetrics"] end
get_node(node_ref)
click to toggle source
# File lib/fog/hadoop/requests/compute/get_node.rb, line 5 def get_node(node_ref) request( :expects => [200, 203], :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/nodes/#{node_ref}" ).body["node"] end
list_nodes()
click to toggle source
# File lib/fog/hadoop/requests/compute/list_nodes.rb, line 5 def list_nodes request( :expects => 200, :method => 'GET', :path => "#{Fog::Hadoop.yarn_endpoint}/nodes" ).body["nodes"]["node"] end