Class EmrContainersStartJobRun

Starts a job run.

Inheritance
System.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(ByRefValue)

Used by jsii to construct an instance of this class from a Javascript-owned object reference
EmrContainersStartJobRun(DeputyBase.DeputyProps)

Used by jsii to construct an instance of this class from DeputyProps
EmrContainersStartJobRun(Construct, String, IEmrContainersStartJobRunProps)

Properties

GrantPrincipal

The principal to grant permissions to.
TaskMetrics
TaskPolicies

Methods

Jsonata(Construct, String, IEmrContainersStartJobRunJsonataProps)

Starts a job run Task using JSONata.
JsonPath(Construct, String, IEmrContainersStartJobRunJsonPathProps)

Starts a job run Task using JSONPath.

Constructors

EmrContainersStartJobRun(ByRefValue)

Used by jsii to construct an instance of this class from a Javascript-owned object reference

protected EmrContainersStartJobRun(ByRefValue reference)
Parameters
reference Amazon.JSII.Runtime.Deputy.ByRefValue

The Javascript-owned object reference

EmrContainersStartJobRun(DeputyBase.DeputyProps)

Used by jsii to construct an instance of this class from DeputyProps

protected EmrContainersStartJobRun(DeputyBase.DeputyProps props)
Parameters
props Amazon.JSII.Runtime.Deputy.DeputyBase.DeputyProps

The deputy props

EmrContainersStartJobRun(Construct, String, IEmrContainersStartJobRunProps)

public EmrContainersStartJobRun(Construct scope, string id, IEmrContainersStartJobRunProps props)
Parameters
scope Constructs.Construct
id System.String

Descriptive identifier for this chainable.

props IEmrContainersStartJobRunProps

Properties

GrantPrincipal

The principal to grant permissions to.

public virtual IPrincipal GrantPrincipal { get; }
Property Value

IPrincipal

TaskMetrics

protected override ITaskMetricsConfig TaskMetrics { get; }
Property Value

ITaskMetricsConfig

Overrides

TaskPolicies

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

PolicyStatement[]

Overrides

Methods

Jsonata(Construct, String, IEmrContainersStartJobRunJsonataProps)

Starts a job run Task using JSONata.

public static EmrContainersStartJobRun Jsonata(Construct scope, string id, IEmrContainersStartJobRunJsonataProps props)
Parameters
scope Constructs.Construct
id System.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

JsonPath(Construct, String, IEmrContainersStartJobRunJsonPathProps)

Starts a job run Task using JSONPath.

public static EmrContainersStartJobRun JsonPath(Construct scope, string id, IEmrContainersStartJobRunJsonPathProps props)
Parameters
scope Constructs.Construct
id System.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

Implements