Interface JobDriver
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
JobDriver.Jsii$Proxy
@Generated(value="jsii-pacmak/1.84.0 (build 5404dcf)",
date="2023-06-19T16:30:48.108Z")
@Stability(Stable)
public interface JobDriver
extends software.amazon.jsii.JsiiSerializable
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.
Example:
EmrContainersStartJobRun.Builder.create(this, "EMR Containers Start Job Run") .virtualCluster(VirtualClusterInput.fromVirtualClusterId("de92jdei2910fwedz")) .releaseLabel(ReleaseLabel.EMR_6_2_0) .jobName("EMR-Containers-Job") .jobDriver(JobDriver.builder() .sparkSubmitJobDriver(SparkSubmitJobDriver.builder() .entryPoint(TaskInput.fromText("local:///usr/lib/spark/examples/src/main/python/pi.py")) .build()) .build()) .applicationConfig(List.of(ApplicationConfiguration.builder() .classification(Classification.SPARK_DEFAULTS) .properties(Map.of( "spark.executor.instances", "1", "spark.executor.memory", "512M")) .build())) .build();
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionstatic JobDriver.Builder
builder()
The job driver parameters specified for spark submit.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getSparkSubmitJobDriver
The job driver parameters specified for spark submit. -
builder
- Returns:
- a
JobDriver.Builder
ofJobDriver
-