Sha256: d143592afb4a619f901ab5219507ac7c79e3a82cfd61a0c354fc595d2bc60e01
Contents?: true
Size: 650 Bytes
Versions: 20
Compression:
Stored size: 650 Bytes
Contents
module Elasticity
class CustomJarStep
include Elasticity::JobFlowStep
attr_accessor :name
attr_accessor :jar
attr_accessor :arguments
attr_accessor :action_on_failure
def initialize(jar)
@name = 'Elasticity Custom Jar Step'
@jar = jar
@arguments = []
@action_on_failure = 'TERMINATE_JOB_FLOW'
end
def to_aws_step(job_flow)
step = {
:action_on_failure => @action_on_failure,
:hadoop_jar_step => {
:jar => @jar
},
:name => @name
}
step[:hadoop_jar_step][:args] = @arguments unless @arguments.empty?
step
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems