Class: Elasticity::S3DistCpStep

Inherits:
CustomJarStep show all
Defined in:
lib/elasticity/s3distcp_step.rb

Instance Attribute Summary

Attributes inherited from CustomJarStep

#action_on_failure, #arguments, #jar, #name

Instance Method Summary collapse

Methods inherited from CustomJarStep

#to_aws_step

Methods included from JobFlowStep

#aws_installation_step_name, #aws_installation_steps, included, #requires_installation?, steps_requiring_installation, #to_aws_step

Constructor Details

#initialize(options) ⇒ S3DistCpStep



5
6
7
8
9
10
11
12
# File 'lib/elasticity/s3distcp_step.rb', line 5

def initialize(options)
  @name = 'Elasticity S3DistCp Step'
  @jar = '/home/hadoop/lib/emr-s3distcp-1.0.jar'
  @arguments = []
  options.each do |argument, value|
    @arguments << '--arg' << argument.to_s << '--arg' << value
  end
end