Class: AWSCDK::StepFunctionsTasks::JobDriver

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
step_functions_tasks/job_driver.rb

Overview

Specify the driver that the EMR Containers job runs on.

The job driver is used to provide an input for the job that will be run.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(spark_submit_job_driver:) ⇒ JobDriver

Returns a new instance of JobDriver.

Parameters:



10
11
12
13
 
# File 'step_functions_tasks/job_driver.rb', line 10

def initialize(spark_submit_job_driver:)
  @spark_submit_job_driver = spark_submit_job_driver.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::SparkSubmitJobDriver.new(**spark_submit_job_driver.transform_keys(&:to_sym)) : spark_submit_job_driver
  Jsii::Type.check_type(@spark_submit_job_driver, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5TcGFya1N1Ym1pdEpvYkRyaXZlciJ9")), "sparkSubmitJobDriver")
end

Instance Attribute Details

#spark_submit_job_driver ⇒ AWSCDK::StepFunctionsTasks::SparkSubmitJobDriver (readonly)

The job driver parameters specified for spark submit.

Returns:

See Also:



19
20
21
 
# File 'step_functions_tasks/job_driver.rb', line 19

def spark_submit_job_driver
  @spark_submit_job_driver
end

Class Method Details

.jsii_properties ⇒ Object 



21
22
23
24
25
 
# File 'step_functions_tasks/job_driver.rb', line 21

def self.jsii_properties
  {
    :spark_submit_job_driver => "sparkSubmitJobDriver",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



27
28
29
30
31
32
33
 
# File 'step_functions_tasks/job_driver.rb', line 27

def to_jsii
  result = {}
  result.merge!({
    "sparkSubmitJobDriver" => @spark_submit_job_driver,
  })
  result.compact
end