class VirtualClusterInput
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.StepFunctions.Tasks.VirtualClusterInput |
Java | software.amazon.awscdk.services.stepfunctions.tasks.VirtualClusterInput |
Python | aws_cdk.aws_stepfunctions_tasks.VirtualClusterInput |
TypeScript (source) | @aws-cdk/aws-stepfunctions-tasks » VirtualClusterInput |
Class that returns a virtual cluster's id depending on input type.
Example
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
Name | Type | Description |
---|---|---|
id | string | The VirtualCluster Id. |
id
Type:
string
The VirtualCluster Id.
Methods
Name | Description |
---|---|
static from | Input for a virtualClusterId from a Task Input. |
static from | Input for virtualClusterId from a literal string. |
TaskInput(taskInput)
static frompublic static fromTaskInput(taskInput: TaskInput): VirtualClusterInput
Parameters
- taskInput
Task
Input
Returns
Input for a virtualClusterId from a Task Input.
VirtualClusterId(virtualClusterId)
static frompublic static fromVirtualClusterId(virtualClusterId: string): VirtualClusterInput
Parameters
- virtualClusterId
string
Returns
Input for virtualClusterId from a literal string.