Package software.amazon.awscdk.services.stepfunctions.tasks

Class EmrCreateCluster

java.lang.Object

software.amazon.jsii.JsiiObject

software.constructs.Construct

software.amazon.awscdk.services.stepfunctions.State

software.amazon.awscdk.services.stepfunctions.TaskStateBase

software.amazon.awscdk.services.stepfunctions.tasks.EmrCreateCluster

All Implemented Interfaces:

IChainable, INextable, software.amazon.jsii.JsiiSerializable, software.constructs.IConstruct, software.constructs.IDependable

@Generated(value="jsii-pacmak/1.129.0 (build eaca441)",
           date="2026-05-13T16:55:18.801Z")
@Stability(Stable)
public class EmrCreateCluster
extends TaskStateBase

A Step Functions Task to create an EMR Cluster.

The ClusterConfiguration is defined as Parameters in the state machine definition.

OUTPUT: the ClusterId.

Example:

 EmrCreateCluster.Builder.create(this, "PrioritizedAllocation")
         .instances(InstancesConfigProperty.builder()
                 .instanceFleets(List.of(InstanceFleetConfigProperty.builder()
                         .instanceFleetType(EmrCreateCluster.getInstanceRoleType().CORE)
                         .instanceTypeConfigs(List.of(InstanceTypeConfigProperty.builder()
                                 .instanceType("m5.large")
                                 .priority(0)
                                 .build(), InstanceTypeConfigProperty.builder()
                                 .instanceType("m5.xlarge")
                                 .priority(1)
                                 .build()))
                         .launchSpecifications(InstanceFleetProvisioningSpecificationsProperty.builder()
                                 .onDemandSpecification(OnDemandProvisioningSpecificationProperty.builder()
                                         .allocationStrategy(EmrCreateCluster.getOnDemandAllocationStrategy().PRIORITIZED)
                                         .build())
                                 .build())
                         .targetOnDemandCapacity(2)
                         .build()))
                 .build())
         .name("PrioritizedCluster")
         .integrationPattern(IntegrationPattern.RUN_JOB)
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	EmrCreateCluster.ApplicationConfigProperty	Properties for the EMR Cluster Applications.
static interface	EmrCreateCluster.AutoScalingPolicyProperty	An automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster.
static interface	EmrCreateCluster.BootstrapActionConfigProperty	Configuration of a bootstrap action.
static final class	EmrCreateCluster.Builder	A fluent builder for EmrCreateCluster.
static enum	EmrCreateCluster.CloudWatchAlarmComparisonOperator	CloudWatch Alarm Comparison Operators.
static interface	EmrCreateCluster.CloudWatchAlarmDefinitionProperty	The definition of a CloudWatch metric alarm, which determines when an automatic scaling activity is triggered.
static enum	EmrCreateCluster.CloudWatchAlarmStatistic	CloudWatch Alarm Statistics.
static enum	EmrCreateCluster.CloudWatchAlarmUnit	CloudWatch Alarm Units.
static enum	EmrCreateCluster.ComputeLimitsUnitType	The unit type for managed scaling policy compute limits.
static interface	EmrCreateCluster.ConfigurationProperty	An optional configuration specification to be used when provisioning cluster instances, which can include configurations for applications and software bundled with Amazon EMR.
static interface	EmrCreateCluster.EbsBlockDeviceConfigProperty	Configuration of requested EBS block device associated with the instance group with count of volumes that will be associated to every instance.
static enum	EmrCreateCluster.EbsBlockDeviceVolumeType	EBS Volume Types.
static interface	EmrCreateCluster.EbsConfigurationProperty	The Amazon EBS configuration of a cluster instance.
static enum	EmrCreateCluster.EmrClusterScaleDownBehavior	The Cluster ScaleDownBehavior specifies the way that individual Amazon EC2 instances terminate when an automatic scale-in activity occurs or an instance group is resized.
static interface	EmrCreateCluster.InstanceFleetConfigProperty	The configuration that defines an instance fleet.
static interface	EmrCreateCluster.InstanceFleetProvisioningSpecificationsProperty	The launch specification for On-Demand and Spot instances in the fleet, which determines the defined duration and provisioning timeout behavior, and allocation strategy.
static interface	EmrCreateCluster.InstanceGroupConfigProperty	Configuration defining a new instance group.
static enum	EmrCreateCluster.InstanceMarket	EC2 Instance Market.
static enum	EmrCreateCluster.InstanceRoleType	Instance Role Types.
static interface	EmrCreateCluster.InstancesConfigProperty	A specification of the number and type of Amazon EC2 instances.
static interface	EmrCreateCluster.InstanceTypeConfigProperty	An instance type configuration for each instance type in an instance fleet, which determines the EC2 instances Amazon EMR attempts to provision to fulfill On-Demand and Spot target capacities.
static interface	EmrCreateCluster.KerberosAttributesProperty	Attributes for Kerberos configuration when Kerberos authentication is enabled using a security configuration.
static interface	EmrCreateCluster.ManagedScalingComputeLimitsProperty	The EC2 unit limits for a managed scaling policy.
static interface	EmrCreateCluster.ManagedScalingPolicyProperty	The managed scaling policy for an Amazon EMR cluster.
static interface	EmrCreateCluster.MetricDimensionProperty	A CloudWatch dimension, which is specified using a Key (known as a Name in CloudWatch), Value pair.
static enum	EmrCreateCluster.OnDemandAllocationStrategy	On-Demand Allocation Strategies.
static interface	EmrCreateCluster.OnDemandProvisioningSpecificationProperty	The launch specification for On-Demand Instances in the instance fleet, which determines the allocation strategy.
static interface	EmrCreateCluster.PlacementTypeProperty	The Amazon EC2 Availability Zone configuration of the cluster (job flow).
static interface	EmrCreateCluster.ScalingActionProperty	The type of adjustment the automatic scaling activity makes when triggered, and the periodicity of the adjustment.
static enum	EmrCreateCluster.ScalingAdjustmentType	AutoScaling Adjustment Type.
static interface	EmrCreateCluster.ScalingConstraintsProperty	The upper and lower EC2 instance limits for an automatic scaling policy.
static interface	EmrCreateCluster.ScalingRuleProperty	A scale-in or scale-out rule that defines scaling activity, including the CloudWatch metric alarm that triggers activity, how EC2 instances are added or removed, and the periodicity of adjustments.
static interface	EmrCreateCluster.ScalingTriggerProperty	The conditions that trigger an automatic scaling activity and the definition of a CloudWatch metric alarm.
static interface	EmrCreateCluster.ScriptBootstrapActionConfigProperty	Configuration of the script to run during a bootstrap action.
static interface	EmrCreateCluster.SimpleScalingPolicyConfigurationProperty	An automatic scaling configuration, which describes how the policy adds or removes instances, the cooldown period, and the number of EC2 instances that will be added each time the CloudWatch metric alarm condition is satisfied.
static enum	EmrCreateCluster.SpotAllocationStrategy	Spot Allocation Strategies.
static interface	EmrCreateCluster.SpotProvisioningSpecificationProperty	The launch specification for Spot instances in the instance fleet, which determines the defined duration and provisioning timeout behavior.
static enum	EmrCreateCluster.SpotTimeoutAction	Spot Timeout Actions.
static interface	EmrCreateCluster.VolumeSpecificationProperty	EBS volume specifications such as volume type, IOPS, and size (GiB) that will be requested for the EBS volume attached to an EC2 instance in the cluster.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.stepfunctions.IChainable

IChainable.Jsii$Default

Nested classes/interfaces inherited from interface software.constructs.IConstruct

software.constructs.IConstruct.Jsii$Default

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.stepfunctions.INextable

INextable.Jsii$Default

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	EmrCreateCluster(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	EmrCreateCluster(software.amazon.jsii.JsiiObjectRef objRef)
	EmrCreateCluster(software.constructs.Construct scope, String id, EmrCreateClusterProps props)

Method Summary

Modifier and Type	Method	Description
IRole	getAutoScalingRole()	The autoscaling role for the EMR Cluster.
IRole	getClusterRole()	The instance role for the EMR Cluster.
IRole	getServiceRole()	The service role for the EMR Cluster.
protected TaskMetricsConfig	getTaskMetrics()
protected List<PolicyStatement>	getTaskPolicies()
static EmrCreateCluster	jsonata(software.constructs.Construct scope, String id, EmrCreateClusterJsonataProps props)	A Step Functions task using JSONata to create an EMR Cluster.
static EmrCreateCluster	jsonPath(software.constructs.Construct scope, String id, EmrCreateClusterJsonPathProps props)	A Step Functions task using JSONPath to create an EMR Cluster.

Methods inherited from class software.amazon.awscdk.services.stepfunctions.TaskStateBase

addCatch, addCatch, addRetry, addRetry, getEndStates, metric, metric, metricFailed, metricFailed, metricHeartbeatTimedOut, metricHeartbeatTimedOut, metricRunTime, metricRunTime, metricScheduled, metricScheduled, metricScheduleTime, metricScheduleTime, metricStarted, metricStarted, metricSucceeded, metricSucceeded, metricTime, metricTime, metricTimedOut, metricTimedOut, next, toStateJson, toStateJson, whenBoundToGraph

Methods inherited from class software.amazon.awscdk.services.stepfunctions.State

addBranch, addChoice, addChoice, addItemProcessor, addItemProcessor, addIterator, addPrefix, bindToGraph, filterNextables, findReachableEndStates, findReachableEndStates, findReachableStates, findReachableStates, getArguments, getAssign, getBranches, getComment, getDefaultChoice, getId, getInputPath, getIteration, getOutputPath, getOutputs, getParameters, getProcessor, getProcessorConfig, getProcessorMode, getQueryLanguage, getResultPath, getResultSelector, getStartState, getStateId, getStateName, makeDefault, makeNext, prefixStates, renderAssign, renderAssign, renderBranches, renderChoices, renderChoices, renderInputOutput, renderItemProcessor, renderIterator, renderNextEnd, renderQueryLanguage, renderQueryLanguage, renderResultSelector, renderRetryCatch, renderRetryCatch, setDefaultChoice, setIteration, setProcessor, setProcessorConfig, setProcessorMode, validateState

Methods inherited from class software.constructs.Construct

getNode, isConstruct, toString, with

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Constructor Details

EmrCreateCluster

protected EmrCreateCluster(software.amazon.jsii.JsiiObjectRef objRef)

EmrCreateCluster

protected EmrCreateCluster(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

EmrCreateCluster

@Stability(Stable)
public EmrCreateCluster(@NotNull
 software.constructs.Construct scope,
 @NotNull
 String id,
 @NotNull
 EmrCreateClusterProps props)

Parameters:

scope - This parameter is required.

id - Descriptive identifier for this chainable. This parameter is required.

props - This parameter is required.

Method Details

jsonata

@Stability(Stable)
@NotNull
public static EmrCreateCluster jsonata(@NotNull
 software.constructs.Construct scope,
 @NotNull
 String id,
 @NotNull
 EmrCreateClusterJsonataProps props)

A Step Functions task using JSONata to create an EMR Cluster.

This task creates a Lambda function to call cross-region AWS API and invokes it.

Parameters:

scope - This parameter is required.

id - This parameter is required.

props - This parameter is required.

jsonPath

@Stability(Stable)
@NotNull
public static EmrCreateCluster jsonPath(@NotNull
 software.constructs.Construct scope,
 @NotNull
 String id,
 @NotNull
 EmrCreateClusterJsonPathProps props)

A Step Functions task using JSONPath to create an EMR Cluster.

This task creates a Lambda function to call cross-region AWS API and invokes it.

Parameters:

scope - This parameter is required.

id - This parameter is required.

props - This parameter is required.

getAutoScalingRole

@Stability(Stable)
@NotNull
public IRole getAutoScalingRole()

The autoscaling role for the EMR Cluster.

Only available after task has been added to a state machine.

getClusterRole

@Stability(Stable)
@NotNull
public IRole getClusterRole()

The instance role for the EMR Cluster.

Only available after task has been added to a state machine.

getServiceRole

@Stability(Stable)
@NotNull
public IRole getServiceRole()

The service role for the EMR Cluster.

Only available after task has been added to a state machine.

getTaskMetrics

@Stability(Stable)
@Nullable
protected TaskMetricsConfig getTaskMetrics()

Specified by:

getTaskMetrics in class TaskStateBase

getTaskPolicies

@Stability(Stable)
@Nullable
protected List<PolicyStatement> getTaskPolicies()

Specified by:

getTaskPolicies in class TaskStateBase