Class EmrContainersStartJobRun

Starts a job run.

Inheritance
object
State
TaskStateBase
EmrContainersStartJobRun
Inherited Members
Namespace: Amazon.CDK.AWS.StepFunctions.Tasks
Assembly: Amazon.CDK.Lib.dll
Syntax (csharp)
public class EmrContainersStartJobRun : TaskStateBase, IChainable, INextable, IGrantable
Syntax (vb)
Public Class EmrContainersStartJobRun Inherits TaskStateBase Implements IChainable, INextable, IGrantable
Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

ExampleMetadata: infused

Examples
new EmrContainersStartJobRun(this, "EMR Containers Start Job Run", new EmrContainersStartJobRunProps {
                 VirtualCluster = VirtualClusterInput.FromVirtualClusterId("de92jdei2910fwedz"),
                 ReleaseLabel = ReleaseLabel.EMR_6_2_0,
                 JobName = "EMR-Containers-Job",
                 JobDriver = new JobDriver {
                     SparkSubmitJobDriver = new SparkSubmitJobDriver {
                         EntryPoint = TaskInput.FromText("local:///usr/lib/spark/examples/src/main/python/pi.py")
                     }
                 },
                 ApplicationConfig = new [] { new ApplicationConfiguration {
                     Classification = Classification.SPARK_DEFAULTS,
                     Properties = new Dictionary<string, string> {
                         { "spark.executor.instances", "1" },
                         { "spark.executor.memory", "512M" }
                     }
                 } }
             });

Synopsis

Constructors

EmrContainersStartJobRun(Construct, string, IEmrContainersStartJobRunProps)

Starts a job run.

Properties

GrantPrincipal

The principal to grant permissions to.
TaskMetrics

Starts a job run.
TaskPolicies

Starts a job run.

Methods

JsonPath(Construct, string, IEmrContainersStartJobRunJsonPathProps)

Starts a job run Task using JSONPath.
Jsonata(Construct, string, IEmrContainersStartJobRunJsonataProps)

Starts a job run Task using JSONata.

Constructors

EmrContainersStartJobRun(Construct, string, IEmrContainersStartJobRunProps)

Starts a job run.

public EmrContainersStartJobRun(Construct scope, string id, IEmrContainersStartJobRunProps props)
Parameters
scope Construct
id string

Descriptive identifier for this chainable.

props IEmrContainersStartJobRunProps
Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

ExampleMetadata: infused

Properties

GrantPrincipal

The principal to grant permissions to.

public virtual IPrincipal GrantPrincipal { get; }
Property Value

IPrincipal

Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

ExampleMetadata: infused

TaskMetrics

Starts a job run.

protected override ITaskMetricsConfig? TaskMetrics { get; }
Property Value

ITaskMetricsConfig

Overrides
Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

ExampleMetadata: infused

TaskPolicies

Starts a job run.

protected override PolicyStatement[]? TaskPolicies { get; }
Property Value

PolicyStatement[]

Overrides
Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

ExampleMetadata: infused

Methods

JsonPath(Construct, string, IEmrContainersStartJobRunJsonPathProps)

Starts a job run Task using JSONPath.

public static EmrContainersStartJobRun JsonPath(Construct scope, string id, IEmrContainersStartJobRunJsonPathProps props)
Parameters
scope Construct
id string
props IEmrContainersStartJobRunJsonPathProps
Returns

EmrContainersStartJobRun

Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

Jsonata(Construct, string, IEmrContainersStartJobRunJsonataProps)

Starts a job run Task using JSONata.

public static EmrContainersStartJobRun Jsonata(Construct scope, string id, IEmrContainersStartJobRunJsonataProps props)
Parameters
scope Construct
id string
props IEmrContainersStartJobRunJsonataProps
Returns

EmrContainersStartJobRun

Remarks

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.

See: https://docs.aws.amazon.com/step-functions/latest/dg/connect-emr-eks.html

Implements