Sha256: 4093529cb4dfec328d4cfe08757109b2ce779e3b96fd38fa009ce3982d7bcca1
Contents?: true
Size: 643 Bytes
Versions: 20
Compression:
Stored size: 643 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(_)
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