@Generated(value="jsii-pacmak/1.74.0 (build 6d08790)",
date="2023-03-14T16:25:36.043Z")
public class EmrContainersStartJobRun
extends TaskStateBase
implements IGrantable
A job is a unit of work that you submit to Amazon EMR on EKS for execution. The work performed by the job can be defined by a Spark jar, PySpark script, or SparkSQL query. A job run is an execution of the job on the virtual cluster.
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();
| Modifier and Type | Class and Description |
|---|---|
static class |
EmrContainersStartJobRun.Builder
A fluent builder for
EmrContainersStartJobRun. |
IGrantable.Jsii$Default, IGrantable.Jsii$ProxyINextable.Jsii$DefaultIChainable.Jsii$DefaultIConstruct.Jsii$Default| Modifier | Constructor and Description |
|---|---|
protected |
EmrContainersStartJobRun(software.amazon.jsii.JsiiObject.InitializationMode initializationMode) |
protected |
EmrContainersStartJobRun(software.amazon.jsii.JsiiObjectRef objRef) |
|
EmrContainersStartJobRun(software.constructs.Construct scope,
java.lang.String id,
EmrContainersStartJobRunProps props) |
| Modifier and Type | Method and Description |
|---|---|
IPrincipal |
getGrantPrincipal()
The principal to grant permissions to.
|
protected TaskMetricsConfig |
getTaskMetrics() |
protected java.util.List<PolicyStatement> |
getTaskPolicies() |
addCatch, addCatch, addRetry, addRetry, getEndStates, metric, metric, metricFailed, metricFailed, metricHeartbeatTimedOut, metricHeartbeatTimedOut, metricRunTime, metricRunTime, metricScheduled, metricScheduled, metricScheduleTime, metricScheduleTime, metricStarted, metricStarted, metricSucceeded, metricSucceeded, metricTime, metricTime, metricTimedOut, metricTimedOut, next, toStateJson, whenBoundToGraphaddBranch, addChoice, addIterator, addPrefix, bindToGraph, filterNextables, findReachableEndStates, findReachableEndStates, findReachableStates, findReachableStates, getBranches, getComment, getDefaultChoice, getId, getInputPath, getIteration, getOutputPath, getParameters, getResultPath, getResultSelector, getStartState, getStateId, makeDefault, makeNext, prefixStates, renderBranches, renderChoices, renderInputOutput, renderIterator, renderNextEnd, renderResultSelector, renderRetryCatch, setDefaultChoice, setIterationgetNode, isConstruct, onPrepare, onSynthesize, onValidate, prepare, synthesize, validateprotected EmrContainersStartJobRun(software.amazon.jsii.JsiiObjectRef objRef)
protected EmrContainersStartJobRun(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
public EmrContainersStartJobRun(software.constructs.Construct scope,
java.lang.String id,
EmrContainersStartJobRunProps props)
scope - This parameter is required.id - This parameter is required.props - This parameter is required.public IPrincipal getGrantPrincipal()
getGrantPrincipal in interface IGrantableprotected TaskMetricsConfig getTaskMetrics()
getTaskMetrics in class TaskStateBaseprotected java.util.List<PolicyStatement> getTaskPolicies()
getTaskPolicies in class TaskStateBase