AddJobFlowSteps

Source: src/AWS/EMR/AddJobFlowSteps.ts

Runtime binding for elasticmapreduce:AddJobFlowSteps — submits work (Spark jobs, Hive queries, custom JARs) to the bound cluster as steps. The cluster id is injected as JobFlowId.

Running Steps

const addSteps = yield* AWS.EMR.AddJobFlowSteps(cluster);

const { StepIds } = yield* addSteps({
  Steps: [{
    Name: "spark-pi",
    ActionOnFailure: "CONTINUE",
    HadoopJarStep: {
      Jar: "command-runner.jar",
      Args: ["spark-example", "SparkPi", "10"],
    },
  }],
});