Module: Rubadoop::Emr::JobflowBuilder::Step::StepBehavior

Included in:
Java, Streaming
Defined in:
lib/rubadoop/emr/jobflow_builder/step.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#action_on_failure ⇒ Object

Returns the value of attribute action_on_failure.



8
9
10
 
# File 'lib/rubadoop/emr/jobflow_builder/step.rb', line 8

def action_on_failure
  @action_on_failure
end

#name ⇒ Object

Returns the value of attribute name.



8
9
10
 
# File 'lib/rubadoop/emr/jobflow_builder/step.rb', line 8

def name
  @name
end

Instance Method Details

#initialize(params, jar, main_class = nil) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/rubadoop/emr/jobflow_builder/step.rb', line 10

def initialize(params, jar, main_class = nil)
  super(params)
  @name = name
  @jar = jar
  @main_class = main_class if main_class
end

#to_h ⇒ Object 



17
18
19
20
21
22
23
24
25
26
 
# File 'lib/rubadoop/emr/jobflow_builder/step.rb', line 17

def to_h
  built = {}
  built[:name] = @name unless @name.nil?
  built[:hadoop_jar_step] = {}
  built[:hadoop_jar_step][:jar] = @jar
  built[:hadoop_jar_step][:main_class] = @main_class unless @main_class.nil?
  built[:hadoop_jar_step][:args] = to_hadoop_cli(skip_jar: true)
  built[:action_on_failure] = @action_on_failure unless @action_on_failure.nil?
  built
end