class AWS::EMR::InstanceGroupCollection

def [] instance_group_id

Returns:
  • (InstanceGroup) - Returns an instance group with the given ID.

Parameters:
  • instance_group_id (String) --
def [] instance_group_id
  InstanceGroup.new(job_flow, instance_group_id)
end

def _each_item options = {}

def _each_item options = {}
  job_flow.instance_group_details.each do |details|
    group = InstanceGroup.new_from(
      :describe_job_flows, details, job_flow,
      details[:instance_group_id])
    yield(group)
  end
end

def create role, instance_type, instance_count, options = {}

Returns:
  • (InstanceGroup) -

Options Hash: (**opitons)
  • :bid_price (Float, String) -- Bid price for each Amazon
  • :market (String) -- Market type of the Amazon EC2
  • :name (String) -- Friendly name given to the group.

Parameters:
  • options (Hash) --
  • instance_count (Integer) -- Target size of instances for the group.
  • instance_type (String) -- The Amazon EC2 instance type to use.
  • role (String) -- The role of the instance group in the cluster.
def create role, instance_type, instance_count, options = {}
  options[:instance_role] = role
  options[:instance_type] = instance_type
  options[:instance_count] = instance_count
  options[:bid_price] = options[:bid_price].to_s if options[:bid_price]
  client_opts = {}
  client_opts[:job_flow_id] = job_flow.job_flow_id
  client_opts[:instance_groups] = [options]
  resp = client.add_instance_groups(client_opts)
  self[resp.data[:instance_group_ids].first]
end

def initialize job_flow, options = {}

Other tags:
    Api: - private

Parameters:
  • job_flow (JobFlow) --
def initialize job_flow, options = {}
  @job_flow = job_flow
  super
end