AWS CDK Reference

Appearance

v2.274.0

VirtualClusterInput Class ​

Class that returns a virtual cluster's id depending on input type.

Source
aws-stepfunctions-tasks/lib/emrcontainers/start-job-run.ts
Type last changed
v2.1.0 · 8 Dec 2021

Example ​

ts
new tasks.EmrContainersStartJobRun(this, 'EMR Containers Start Job Run', {
  virtualCluster: tasks.VirtualClusterInput.fromVirtualClusterId('de92jdei2910fwedz'),
  releaseLabel: tasks.ReleaseLabel.EMR_6_2_0,
  jobName: 'EMR-Containers-Job',
  jobDriver: {
    sparkSubmitJobDriver: {
      entryPoint: sfn.TaskInput.fromText('local:///usr/lib/spark/examples/src/main/python/pi.py'),
    },
  },
  applicationConfig: [{
    classification: tasks.Classification.SPARK_DEFAULTS,
    properties: {
      'spark.executor.instances': '1',
      'spark.executor.memory': '512M',
    },
  }],
});

Properties ​

idstringidstridStringIdstringId*stringrequired#
The VirtualCluster Id.

Methods ​

fromTaskInput(taskInput: TaskInput): VirtualClusterInput // chainable@staticmethod def from_task_input(task_input: TaskInput) -> VirtualClusterInputpublic static VirtualClusterInput fromTaskInput(TaskInput taskInput)public static VirtualClusterInput FromTaskInput(TaskInput taskInput)func FromTaskInput(TaskInput TaskInput) VirtualClusterInputstatic#
Input for a virtualClusterId from a Task Input.
fromVirtualClusterId(virtualClusterId: string): VirtualClusterInput // chainable@staticmethod def from_virtual_cluster_id(virtual_cluster_id: str) -> VirtualClusterInputpublic static VirtualClusterInput fromVirtualClusterId(String virtualClusterId)public static VirtualClusterInput FromVirtualClusterId(string virtualClusterId)func FromVirtualClusterId(VirtualClusterId *string) VirtualClusterInputstatic#
Input for virtualClusterId from a literal string.