Awso_emr_asyncSourceval add_instance_fleet :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.AddInstanceFleetInput.t ->
(Awso_emr.Values.AddInstanceFleetOutput.t,
Awso_emr.Values.AddInstanceFleetOutput.error)
Result.t
Async.Deferred.tval add_instance_groups :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.AddInstanceGroupsInput.t ->
(Awso_emr.Values.AddInstanceGroupsOutput.t,
Awso_emr.Values.AddInstanceGroupsOutput.error)
Result.t
Async.Deferred.tval add_job_flow_steps :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.AddJobFlowStepsInput.t ->
(Awso_emr.Values.AddJobFlowStepsOutput.t,
Awso_emr.Values.AddJobFlowStepsOutput.error)
Result.t
Async.Deferred.tval add_tags :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.AddTagsInput.t ->
(Awso_emr.Values.AddTagsOutput.t, Awso_emr.Values.AddTagsOutput.error)
Result.t
Async.Deferred.tval cancel_steps :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.CancelStepsInput.t ->
(Awso_emr.Values.CancelStepsOutput.t,
Awso_emr.Values.CancelStepsOutput.error)
Result.t
Async.Deferred.tval create_persistent_app_u_i :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.CreatePersistentAppUIInput.t ->
(Awso_emr.Values.CreatePersistentAppUIOutput.t,
Awso_emr.Values.CreatePersistentAppUIOutput.error)
Result.t
Async.Deferred.tval create_security_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.CreateSecurityConfigurationInput.t ->
(Awso_emr.Values.CreateSecurityConfigurationOutput.t,
Awso_emr.Values.CreateSecurityConfigurationOutput.error)
Result.t
Async.Deferred.tval create_studio :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.CreateStudioInput.t ->
(Awso_emr.Values.CreateStudioOutput.t,
Awso_emr.Values.CreateStudioOutput.error)
Result.t
Async.Deferred.tval create_studio_session_mapping :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.CreateStudioSessionMappingInput.t ->
(unit, unit) Result.t Async.Deferred.tval delete_security_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DeleteSecurityConfigurationInput.t ->
(Awso_emr.Values.DeleteSecurityConfigurationOutput.t,
Awso_emr.Values.DeleteSecurityConfigurationOutput.error)
Result.t
Async.Deferred.tval delete_studio :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DeleteStudioInput.t ->
(unit, unit) Result.t Async.Deferred.tval delete_studio_session_mapping :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DeleteStudioSessionMappingInput.t ->
(unit, unit) Result.t Async.Deferred.tval describe_cluster :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeClusterInput.t ->
(Awso_emr.Values.DescribeClusterOutput.t,
Awso_emr.Values.DescribeClusterOutput.error)
Result.t
Async.Deferred.tval describe_job_flows :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeJobFlowsInput.t ->
(Awso_emr.Values.DescribeJobFlowsOutput.t,
Awso_emr.Values.DescribeJobFlowsOutput.error)
Result.t
Async.Deferred.tval describe_notebook_execution :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeNotebookExecutionInput.t ->
(Awso_emr.Values.DescribeNotebookExecutionOutput.t,
Awso_emr.Values.DescribeNotebookExecutionOutput.error)
Result.t
Async.Deferred.tval describe_persistent_app_u_i :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribePersistentAppUIInput.t ->
(Awso_emr.Values.DescribePersistentAppUIOutput.t,
Awso_emr.Values.DescribePersistentAppUIOutput.error)
Result.t
Async.Deferred.tval describe_release_label :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeReleaseLabelInput.t ->
(Awso_emr.Values.DescribeReleaseLabelOutput.t,
Awso_emr.Values.DescribeReleaseLabelOutput.error)
Result.t
Async.Deferred.tval describe_security_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeSecurityConfigurationInput.t ->
(Awso_emr.Values.DescribeSecurityConfigurationOutput.t,
Awso_emr.Values.DescribeSecurityConfigurationOutput.error)
Result.t
Async.Deferred.tval describe_step :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeStepInput.t ->
(Awso_emr.Values.DescribeStepOutput.t,
Awso_emr.Values.DescribeStepOutput.error)
Result.t
Async.Deferred.tval describe_studio :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.DescribeStudioInput.t ->
(Awso_emr.Values.DescribeStudioOutput.t,
Awso_emr.Values.DescribeStudioOutput.error)
Result.t
Async.Deferred.tval get_auto_termination_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetAutoTerminationPolicyInput.t ->
(Awso_emr.Values.GetAutoTerminationPolicyOutput.t,
Awso_emr.Values.GetAutoTerminationPolicyOutput.error)
Result.t
Async.Deferred.tval get_block_public_access_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetBlockPublicAccessConfigurationInput.t ->
(Awso_emr.Values.GetBlockPublicAccessConfigurationOutput.t,
Awso_emr.Values.GetBlockPublicAccessConfigurationOutput.error)
Result.t
Async.Deferred.tval get_cluster_session_credentials :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetClusterSessionCredentialsInput.t ->
(Awso_emr.Values.GetClusterSessionCredentialsOutput.t,
Awso_emr.Values.GetClusterSessionCredentialsOutput.error)
Result.t
Async.Deferred.tval get_managed_scaling_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetManagedScalingPolicyInput.t ->
(Awso_emr.Values.GetManagedScalingPolicyOutput.t,
Awso_emr.Values.GetManagedScalingPolicyOutput.error)
Result.t
Async.Deferred.tval get_on_cluster_app_u_i_presigned_u_r_l :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetOnClusterAppUIPresignedURLInput.t ->
(Awso_emr.Values.GetOnClusterAppUIPresignedURLOutput.t,
Awso_emr.Values.GetOnClusterAppUIPresignedURLOutput.error)
Result.t
Async.Deferred.tval get_persistent_app_u_i_presigned_u_r_l :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetPersistentAppUIPresignedURLInput.t ->
(Awso_emr.Values.GetPersistentAppUIPresignedURLOutput.t,
Awso_emr.Values.GetPersistentAppUIPresignedURLOutput.error)
Result.t
Async.Deferred.tval get_studio_session_mapping :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.GetStudioSessionMappingInput.t ->
(Awso_emr.Values.GetStudioSessionMappingOutput.t,
Awso_emr.Values.GetStudioSessionMappingOutput.error)
Result.t
Async.Deferred.tval list_bootstrap_actions :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListBootstrapActionsInput.t ->
(Awso_emr.Values.ListBootstrapActionsOutput.t,
Awso_emr.Values.ListBootstrapActionsOutput.error)
Result.t
Async.Deferred.tval list_clusters :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListClustersInput.t ->
(Awso_emr.Values.ListClustersOutput.t,
Awso_emr.Values.ListClustersOutput.error)
Result.t
Async.Deferred.tval list_instance_fleets :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListInstanceFleetsInput.t ->
(Awso_emr.Values.ListInstanceFleetsOutput.t,
Awso_emr.Values.ListInstanceFleetsOutput.error)
Result.t
Async.Deferred.tval list_instance_groups :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListInstanceGroupsInput.t ->
(Awso_emr.Values.ListInstanceGroupsOutput.t,
Awso_emr.Values.ListInstanceGroupsOutput.error)
Result.t
Async.Deferred.tval list_instances :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListInstancesInput.t ->
(Awso_emr.Values.ListInstancesOutput.t,
Awso_emr.Values.ListInstancesOutput.error)
Result.t
Async.Deferred.tval list_notebook_executions :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListNotebookExecutionsInput.t ->
(Awso_emr.Values.ListNotebookExecutionsOutput.t,
Awso_emr.Values.ListNotebookExecutionsOutput.error)
Result.t
Async.Deferred.tval list_release_labels :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListReleaseLabelsInput.t ->
(Awso_emr.Values.ListReleaseLabelsOutput.t,
Awso_emr.Values.ListReleaseLabelsOutput.error)
Result.t
Async.Deferred.tval list_security_configurations :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListSecurityConfigurationsInput.t ->
(Awso_emr.Values.ListSecurityConfigurationsOutput.t,
Awso_emr.Values.ListSecurityConfigurationsOutput.error)
Result.t
Async.Deferred.tval list_steps :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListStepsInput.t ->
(Awso_emr.Values.ListStepsOutput.t, Awso_emr.Values.ListStepsOutput.error)
Result.t
Async.Deferred.tval list_studio_session_mappings :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListStudioSessionMappingsInput.t ->
(Awso_emr.Values.ListStudioSessionMappingsOutput.t,
Awso_emr.Values.ListStudioSessionMappingsOutput.error)
Result.t
Async.Deferred.tval list_studios :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListStudiosInput.t ->
(Awso_emr.Values.ListStudiosOutput.t,
Awso_emr.Values.ListStudiosOutput.error)
Result.t
Async.Deferred.tval list_supported_instance_types :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ListSupportedInstanceTypesInput.t ->
(Awso_emr.Values.ListSupportedInstanceTypesOutput.t,
Awso_emr.Values.ListSupportedInstanceTypesOutput.error)
Result.t
Async.Deferred.tval modify_cluster :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ModifyClusterInput.t ->
(Awso_emr.Values.ModifyClusterOutput.t,
Awso_emr.Values.ModifyClusterOutput.error)
Result.t
Async.Deferred.tval modify_instance_fleet :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ModifyInstanceFleetInput.t ->
(unit, unit) Result.t Async.Deferred.tval modify_instance_groups :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.ModifyInstanceGroupsInput.t ->
(unit, unit) Result.t Async.Deferred.tval put_auto_scaling_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.PutAutoScalingPolicyInput.t ->
(Awso_emr.Values.PutAutoScalingPolicyOutput.t,
Awso_emr.Values.PutAutoScalingPolicyOutput.error)
Result.t
Async.Deferred.tval put_auto_termination_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.PutAutoTerminationPolicyInput.t ->
(Awso_emr.Values.PutAutoTerminationPolicyOutput.t,
Awso_emr.Values.PutAutoTerminationPolicyOutput.error)
Result.t
Async.Deferred.tval put_block_public_access_configuration :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.PutBlockPublicAccessConfigurationInput.t ->
(Awso_emr.Values.PutBlockPublicAccessConfigurationOutput.t,
Awso_emr.Values.PutBlockPublicAccessConfigurationOutput.error)
Result.t
Async.Deferred.tval put_managed_scaling_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.PutManagedScalingPolicyInput.t ->
(Awso_emr.Values.PutManagedScalingPolicyOutput.t,
Awso_emr.Values.PutManagedScalingPolicyOutput.error)
Result.t
Async.Deferred.tval remove_auto_scaling_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.RemoveAutoScalingPolicyInput.t ->
(Awso_emr.Values.RemoveAutoScalingPolicyOutput.t,
Awso_emr.Values.RemoveAutoScalingPolicyOutput.error)
Result.t
Async.Deferred.tval remove_auto_termination_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.RemoveAutoTerminationPolicyInput.t ->
(Awso_emr.Values.RemoveAutoTerminationPolicyOutput.t,
Awso_emr.Values.RemoveAutoTerminationPolicyOutput.error)
Result.t
Async.Deferred.tval remove_managed_scaling_policy :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.RemoveManagedScalingPolicyInput.t ->
(Awso_emr.Values.RemoveManagedScalingPolicyOutput.t,
Awso_emr.Values.RemoveManagedScalingPolicyOutput.error)
Result.t
Async.Deferred.tval remove_tags :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.RemoveTagsInput.t ->
(Awso_emr.Values.RemoveTagsOutput.t, Awso_emr.Values.RemoveTagsOutput.error)
Result.t
Async.Deferred.tval run_job_flow :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.RunJobFlowInput.t ->
(Awso_emr.Values.RunJobFlowOutput.t, Awso_emr.Values.RunJobFlowOutput.error)
Result.t
Async.Deferred.tval set_keep_job_flow_alive_when_no_steps :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.SetKeepJobFlowAliveWhenNoStepsInput.t ->
(unit, unit) Result.t Async.Deferred.tval set_termination_protection :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.SetTerminationProtectionInput.t ->
(unit, unit) Result.t Async.Deferred.tval set_unhealthy_node_replacement :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.SetUnhealthyNodeReplacementInput.t ->
(unit, unit) Result.t Async.Deferred.tval set_visible_to_all_users :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.SetVisibleToAllUsersInput.t ->
(unit, unit) Result.t Async.Deferred.tval start_notebook_execution :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.StartNotebookExecutionInput.t ->
(Awso_emr.Values.StartNotebookExecutionOutput.t,
Awso_emr.Values.StartNotebookExecutionOutput.error)
Result.t
Async.Deferred.tval stop_notebook_execution :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.StopNotebookExecutionInput.t ->
(unit, unit) Result.t Async.Deferred.tval terminate_job_flows :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.TerminateJobFlowsInput.t ->
(unit, unit) Result.t Async.Deferred.tval update_studio :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.UpdateStudioInput.t ->
(unit, unit) Result.t Async.Deferred.tval update_studio_session_mapping :
?endpoint_url:string ->
?cfg:Awso.Cfg.t ->
Awso_emr.Values.UpdateStudioSessionMappingInput.t ->
(unit, unit) Result.t Async.Deferred.tinclude module type of struct include Awso_emr.Values endval structure_to_value_aux :
('a * 'b option) list ->
f:(('a * 'b) list -> 'c) ->
[> `Structure of 'c ]val structure_to_wrapped_value :
wrapper:'a ->
response:'a ->
('b * 'c option) list ->
[> `Structure of ('a * [> `Structure of ('b * 'c) list ]) list ]EBS volume specifications such as volume type, IOPS, size (GiB) and throughput (MiB/s) that are requested for the EBS volume attached to an Amazon EC2 instance in the cluster.
Configuration of requested EBS block device associated with the instance group with count of volumes that are associated to every instance.
The Amazon EBS configuration of a cluster instance.
module Configuration = Awso_emr.Values.ConfigurationAmazon EMR releases 4.x or later. An optional configuration specification to be used when provisioning cluster instances, which can include configurations for applications and software bundled with Amazon EMR. A configuration consists of a classification, properties, and optional nested configurations. A classification refers to an application-specific configuration file. Properties are the settings you want to change in that file. For more information, see Configuring Applications.
module ConfigurationList = Awso_emr.Values.ConfigurationListAn instance type configuration for each instance type in an instance fleet, which determines the Amazon EC2 instances Amazon EMR attempts to provision to fulfill On-Demand and Spot target capacities. When you use an allocation strategy, you can include a maximum of 30 instance type configurations for a fleet. For more information about how to use an allocation strategy, see Configure Instance Fleets. Without an allocation strategy, you may specify a maximum of five instance type configurations for a fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
module SpotProvisioningAllocationStrategy =
Awso_emr.Values.SpotProvisioningAllocationStrategyThe resize specification for Spot Instances in the instance fleet, which contains the resize timeout period.
module OnDemandProvisioningAllocationStrategy =
Awso_emr.Values.OnDemandProvisioningAllocationStrategymodule OnDemandCapacityReservationUsageStrategy =
Awso_emr.Values.OnDemandCapacityReservationUsageStrategymodule OnDemandCapacityReservationPreference =
Awso_emr.Values.OnDemandCapacityReservationPreferencemodule OnDemandCapacityReservationOptions =
Awso_emr.Values.OnDemandCapacityReservationOptionsDescribes the strategy for using unused Capacity Reservations for fulfilling On-Demand capacity.
The resize specification for On-Demand Instances in the instance fleet, which contains the resize timeout period.
module InstanceFleetResizingSpecifications =
Awso_emr.Values.InstanceFleetResizingSpecificationsThe resize specification for On-Demand and Spot Instances in the fleet.
The launch specification for Spot Instances in the instance fleet, which determines the defined duration, provisioning timeout behavior, and allocation strategy. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions. Spot Instance allocation strategy is available in Amazon EMR releases 5.12.1 and later. Spot Instances with a defined duration (also known as Spot blocks) are no longer available to new customers from July 1, 2021. For customers who have previously used the feature, we will continue to support Spot Instances with a defined duration until December 31, 2022.
The launch specification for On-Demand Instances in the instance fleet, which determines the allocation strategy. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions. On-Demand Instances allocation strategy is available in Amazon EMR releases 5.12.1 and later.
module InstanceFleetProvisioningSpecifications =
Awso_emr.Values.InstanceFleetProvisioningSpecificationsThe launch specification for On-Demand and Spot Instances in the fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions. On-Demand and Spot instance allocation strategies are available in Amazon EMR releases 5.12.1 and later.
The configuration that defines an instance fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Adds an instance fleet to a running cluster. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x.
This exception occurs when there is something wrong with user input.
This exception occurs when there is an internal failure in the Amazon EMR service.
Adds an instance fleet to a running cluster. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x.
A CloudWatch dimension, which is specified using a Key (known as a Name in CloudWatch), Value pair. By default, Amazon EMR uses one dimension whose Key is JobFlowID and Value is a variable representing the cluster ID, which is ${emr.clusterId}. This enables the rule to bootstrap when the cluster ID becomes available.
The definition of a CloudWatch metric alarm, which determines when an automatic scaling activity is triggered. When the defined alarm conditions are satisfied, scaling activity begins.
The conditions that trigger an automatic scaling activity.
An automatic scaling configuration, which describes how the policy adds or removes instances, the cooldown period, and the number of Amazon EC2 instances that will be added each time the CloudWatch metric alarm condition is satisfied.
The type of adjustment the automatic scaling activity makes when triggered, and the periodicity of the adjustment.
A scale-in or scale-out rule that defines scaling activity, including the CloudWatch metric alarm that triggers activity, how Amazon EC2 instances are added or removed, and the periodicity of adjustments. The automatic scaling policy for an instance group can comprise one or more automatic scaling rules.
The upper and lower Amazon EC2 instance limits for an automatic scaling policy. Automatic scaling activities triggered by automatic scaling rules will not cause an instance group to grow above or below these limits.
An automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. An automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric. See PutAutoScalingPolicy.
Configuration defining a new instance group.
Input to an AddInstanceGroups call.
Indicates that an error occurred while processing the request and that the request was not completed.
Output from an AddInstanceGroups call.
The Amazon S3 configuration for monitoring log publishing. You can configure your step to send log information to Amazon S3. When it's specified, it takes precedence over the cluster's logging configuration. If you don't specify this configuration entirely, or omit individual fields, EMR falls back to cluster-level logging behavior.
Object that holds configuration properties for logging.
A key-value pair.
A job flow step consisting of a JAR file whose main function will be executed. The main function submits a job for Hadoop to execute and waits for the job to finish or fail.
Specification for a cluster (job flow) step.
The input argument to the AddJobFlowSteps operation.
The output for the AddJobFlowSteps operation.
A key-value pair containing user-defined metadata that you can associate with an Amazon EMR resource. Tags make it easier to associate clusters in various ways, such as grouping clusters to track your Amazon EMR resource allocation costs. For more information, see Tag Clusters.
This input identifies an Amazon EMR resource and a list of tags to attach.
This output indicates the result of adding tags to a resource.
With Amazon EMR release version 4.0 and later, the only accepted parameter is the application name. To pass arguments to applications, you use configuration classifications specified using configuration JSON objects. For more information, see Configuring Applications. With earlier Amazon EMR releases, the application is any Amazon or third-party software that you can add to the cluster. This structure contains a list of strings that indicates the software to use with the cluster and accepts a user argument list. Amazon EMR accepts and forwards the argument list to the corresponding installation script as bootstrap action argument.
module AutoScalingPolicyStateChangeReasonCode =
Awso_emr.Values.AutoScalingPolicyStateChangeReasonCodemodule AutoScalingPolicyStateChangeReason =
Awso_emr.Values.AutoScalingPolicyStateChangeReasonThe reason for an AutoScalingPolicyStatus change.
The status of an automatic scaling policy.
An automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric. See PutAutoScalingPolicy.
An auto-termination policy for an Amazon EMR cluster. An auto-termination policy defines the amount of idle time in seconds after which a cluster automatically terminates. For alternative cluster termination options, see Control cluster termination.
A list of port ranges that are permitted to allow inbound traffic from all public IP addresses. To specify a single port, use the same value for MinRange and MaxRange.
A configuration for Amazon EMR block public access. When BlockPublicSecurityGroupRules is set to true, Amazon EMR prevents cluster creation if one of the cluster's security groups has a rule that allows inbound traffic from 0.0.0.0/0 or ::/0 on a port, unless the port is specified as an exception using PermittedPublicSecurityGroupRuleRanges.
module BlockPublicAccessConfigurationMetadata =
Awso_emr.Values.BlockPublicAccessConfigurationMetadataProperties that describe the Amazon Web Services principal that created the BlockPublicAccessConfiguration using the PutBlockPublicAccessConfiguration action as well as the date and time that the configuration was created. Each time a configuration for block public access is updated, Amazon EMR updates this metadata.
Configuration of the script to run during a bootstrap action.
Configuration of a bootstrap action.
Reports the configuration of a bootstrap action in a cluster (job flow).
Specification of the status of a CancelSteps request. Available only in Amazon EMR version 4.8.0 and later, excluding version 5.0.0.
The input argument to the CancelSteps operation.
The output for the CancelSteps operation.
Holds CloudWatch log configuration settings and metadata that specify settings like log files to monitor and where to send them.
Placement group configuration for an Amazon EMR cluster. The configuration specifies the placement strategy that can be applied to instance roles during cluster creation. To use this configuration, consider attaching managed policy AmazonElasticMapReducePlacementGroupPolicy to the Amazon EMR role.
Configuration for S3 logging behavior in EMR clusters. Defines how different types of logs are uploaded to S3 based on the specified upload policies for each log type.
Contains CloudWatch log configuration and S3 logging configuration metadata and settings.
Attributes for Kerberos configuration when Kerberos authentication is enabled using a security configuration. For more information see Use Kerberos Authentication in the Amazon EMR Management Guide.
Provides information about the Amazon EC2 instances in a cluster grouped by category. For example, key name, subnet ID, IAM instance profile, and so on.
A tuple that provides information about an error that caused a cluster to terminate.
Represents the timeline of the cluster's lifecycle.
The reason that the cluster changed to its current state.
The detailed status of the cluster.
The detailed description of the cluster.
The summary description of the cluster.
An entity describing an executable that runs on a cluster.
The Amazon EC2 unit limits for a managed scaling policy. The managed scaling activity of a cluster can not be above or below these limits. The limit only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
The EMR container configuration.
Creates a persistent application user interface.
Creates a persistent application user interface.
Creates a security configuration, which is stored in the service and can be specified when a cluster is created.
Creates a security configuration, which is stored in the service and can be specified when a cluster is created.
Creates a new Amazon EMR Studio.
Creates a new Amazon EMR Studio.
Maps a user or group to the Amazon EMR Studio specified by StudioId, and applies a session policy to refine Studio permissions for that user or group. Use CreateStudioSessionMapping to assign users to a Studio when you use IAM Identity Center authentication. For instructions on how to assign users to a Studio when you use IAM authentication, see Assign a user or group to your EMR Studio.
The username and password that you use to connect to cluster endpoints.
The credentials that you can use to connect to cluster endpoints. Credentials consist of a username and a password.
Deletes a security configuration.
Deletes a security configuration.
Removes an Amazon EMR Studio from the Studio metadata store.
Removes a user or group from an Amazon EMR Studio.
This input determines which cluster to describe.
This output contains the description of the cluster.
The input for the DescribeJobFlows operation.
The execution state of a step.
Combines the execution state and configuration of a step.
The Amazon EC2 Availability Zone configuration of the cluster (job flow).
Detailed information about an instance group.
Specify the type of Amazon EC2 instances that the cluster (job flow) runs on.
Describes the status of the cluster (job flow).
A description of a cluster (job flow).
The output for the DescribeJobFlows operation.
Provides details of a notebook execution.
The Amazon S3 location that stores the notebook execution output.
The Amazon S3 location that stores the notebook execution input.
Specifies the execution engine (cluster) to run the notebook and perform the notebook execution, for example, an Amazon EMR cluster.
A notebook execution. An execution is a specific instance that an Amazon EMR Notebook is run using the StartNotebookExecution action.
Provides details of a notebook execution.
Describes a persistent application user interface.
Holds persistent application user interface information. Applications installed on the Amazon EMR cluster publish user interfaces as web sites to monitor cluster activity.
Describes a persistent application user interface.
Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label. Can also list Amazon EMR releases that support a specified version of Spark.
The returned release label application names or versions.
The Amazon Linux release specified for a cluster in the RunJobFlow request.
Provides Amazon EMR release label details, such as the releases available the Region where the API request is run, and the available applications for a specific Amazon EMR release label. Can also list Amazon EMR releases that support a specified version of Spark.
module DescribeSecurityConfigurationInput =
Awso_emr.Values.DescribeSecurityConfigurationInputProvides the details of a security configuration by returning the configuration JSON.
module DescribeSecurityConfigurationOutput =
Awso_emr.Values.DescribeSecurityConfigurationOutputProvides the details of a security configuration by returning the configuration JSON.
This input determines which step to describe.
The timeline of the cluster step lifecycle.
The details of the step state change reason.
The details of the step failure. The service attempts to detect the root cause for many common failures.
The execution status details of the cluster step.
A cluster step consisting of a JAR file whose main function will be executed. The main function submits a job for Hadoop to execute and waits for the job to finish or fail.
This represents a step in a cluster.
This output contains the description of the cluster step.
Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.
Details for an Amazon EMR Studio including ID, creation time, name, and so on.
Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio access URL, and so on.
Configuration of requested EBS block device associated with the instance group.
EBS block device that's attached to an Amazon EC2 instance.
Returns the auto-termination policy for an Amazon EMR cluster.
Returns the auto-termination policy for an Amazon EMR cluster.
module GetBlockPublicAccessConfigurationInput =
Awso_emr.Values.GetBlockPublicAccessConfigurationInputReturns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
module GetBlockPublicAccessConfigurationOutput =
Awso_emr.Values.GetBlockPublicAccessConfigurationOutputReturns the Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
Provides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated. You can use these credentials to connect to cluster endpoints that support username and password authentication.
module GetClusterSessionCredentialsOutput =
Awso_emr.Values.GetClusterSessionCredentialsOutputProvides temporary, HTTP basic credentials that are associated with a given runtime IAM role and used by a cluster with fine-grained access control activated. You can use these credentials to connect to cluster endpoints that support username and password authentication.
Fetches the attached managed scaling policy for an Amazon EMR cluster.
module UtilizationPerformanceIndexInteger =
Awso_emr.Values.UtilizationPerformanceIndexIntegerManaged scaling policy for an Amazon EMR cluster. The policy specifies the limits for resources that can be added or terminated from a cluster. The policy only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
Fetches the attached managed scaling policy for an Amazon EMR cluster.
module GetOnClusterAppUIPresignedURLInput =
Awso_emr.Values.GetOnClusterAppUIPresignedURLInputThe presigned URL properties for the cluster's application user interface.
module GetOnClusterAppUIPresignedURLOutput =
Awso_emr.Values.GetOnClusterAppUIPresignedURLOutputThe presigned URL properties for the cluster's application user interface.
module GetPersistentAppUIPresignedURLInput =
Awso_emr.Values.GetPersistentAppUIPresignedURLInputThe presigned URL properties for the cluster's application user interface.
module GetPersistentAppUIPresignedURLOutput =
Awso_emr.Values.GetPersistentAppUIPresignedURLOutputThe presigned URL properties for the cluster's application user interface.
Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).
Details for an Amazon EMR Studio session mapping including creation time, user or group ID, Studio ID, and so on.
Fetches mapping details for the specified Amazon EMR Studio and identity (user or group).
The timeline of the instance lifecycle.
The details of the status change reason for the instance.
The instance status details.
Represents an Amazon EC2 instance provisioned as part of cluster.
The configuration specification for each instance type in an instance fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Provides historical timestamps for the instance fleet, including the time of creation, the time it became ready to run jobs, and the time of termination. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
module InstanceFleetStateChangeReasonCode =
Awso_emr.Values.InstanceFleetStateChangeReasonCodeProvides status change reason details for the instance fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
The status of the instance fleet. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Describes an instance fleet, which is a group of Amazon EC2 instances that host a particular node type (master, core, or task) in an Amazon EMR cluster. Instance fleets can consist of a mix of instance types and On-Demand and Spot Instances, which are provisioned to meet a defined target capacity. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Configuration parameters for an instance fleet modification request. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Custom policy for requesting termination protection or termination of specific instances when shrinking an instance group.
Policy for customizing shrink operations. Allows configuration of decommissioning timeout and targeted instance shrinking.
The timeline of the instance group lifecycle.
module InstanceGroupStateChangeReasonCode =
Awso_emr.Values.InstanceGroupStateChangeReasonCodeThe status change reason details for the instance group.
The details of the instance group status.
This entity represents an instance group, which is a group of instances that have common purpose. For example, CORE instance group is used for HDFS.
Modify the size or configurations of an instance group.
A description of the Amazon EC2 instance on which the cluster (job flow) runs. A valid JobFlowInstancesConfig must contain either InstanceGroups or InstanceFleets. They cannot be used together. You may also have MasterInstanceType, SlaveInstanceType, and InstanceCount (all three must be present), but we don't recommend this configuration.
This input determines which bootstrap actions to retrieve.
This output contains the bootstrap actions detail.
This input determines how the ListClusters action filters the list of clusters that it returns.
This contains a ClusterSummaryList with the cluster details; for example, the cluster IDs, names, and status.
Lists all available details about the instance fleets in a cluster. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Lists all available details about the instance fleets in a cluster. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
This input determines which instance groups to retrieve.
This input determines which instance groups to retrieve.
This input determines which instances to list.
This output contains the list of instances.
Provides summaries of all notebook executions. You can filter the list based on multiple criteria such as status, time range, and editor id. Returns a maximum of 50 notebook executions and a marker to track the paging of a longer notebook execution list across multiple ListNotebookExecutions calls.
Details for a notebook execution. The details include information such as the unique ID and status of the notebook execution.
Provides summaries of all notebook executions. You can filter the list based on multiple criteria such as status, time range, and editor id. Returns a maximum of 50 notebook executions and a marker to track the paging of a longer notebook execution list across multiple ListNotebookExecutions calls.
The release label filters by application or version prefix.
Retrieves release labels of Amazon EMR services in the Region where the API is called.
Retrieves release labels of Amazon EMR services in the Region where the API is called.
Lists all the security configurations visible to this account, providing their creation dates and times, and their names. This call returns a maximum of 50 clusters per call, but returns a marker to track the paging of the cluster list across multiple ListSecurityConfigurations calls.
The creation date and time, and name, of a security configuration.
Lists all the security configurations visible to this account, providing their creation dates and times, and their names. This call returns a maximum of 50 clusters per call, but returns a marker to track the paging of the cluster list across multiple ListSecurityConfigurations calls.
This input determines which steps to list.
The summary of the cluster step.
This output contains the list of steps returned in reverse order. This means that the last step is the first element in the list.
Returns a list of all user or group session mappings for the Amazon EMR Studio specified by StudioId.
Details for an Amazon EMR Studio session mapping. The details do not include the time the session mapping was last modified.
Returns a list of all user or group session mappings for the Amazon EMR Studio specified by StudioId.
Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account. The list includes details such as ID, Studio Access URL, and creation time for each Studio.
Details for an Amazon EMR Studio, including ID, Name, VPC, and Description. To fetch additional details such as subnets, IAM roles, security groups, and tags for the Studio, use the DescribeStudio API.
Returns a list of all Amazon EMR Studios associated with the Amazon Web Services account. The list includes details such as ID, Studio Access URL, and creation time for each Studio.
A list of the instance types that Amazon EMR supports. You can filter the list by Amazon Web Services Region and Amazon EMR release.
An instance type that the specified Amazon EMR release supports.
A list of the instance types that Amazon EMR supports. You can filter the list by Amazon Web Services Region and Amazon EMR release.
Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.
Modifies the number of steps that can be executed concurrently for the cluster specified using ClusterID.
Modifies the target On-Demand and target Spot capacities for the instance fleet with the specified InstanceFleetID within the cluster specified using ClusterID. The call either succeeds or fails atomically. The instance fleet configuration is available only in Amazon EMR releases 4.8.0 and later, excluding 5.0.x versions.
Change the size of some instance groups.
The list of supported product configurations that allow user-supplied arguments. Amazon EMR accepts these arguments and forwards them to the corresponding installation script as bootstrap action arguments.
The Amazon S3 location that stores the notebook execution input.
The Amazon S3 location that stores the notebook execution output.
Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric.
Creates or updates an automatic scaling policy for a core instance group or task instance group in an Amazon EMR cluster. The automatic scaling policy defines how an instance group dynamically adds and terminates Amazon EC2 instances in response to the value of a CloudWatch metric.
Auto-termination is supported in Amazon EMR releases 5.30.0 and 6.1.0 and later. For more information, see Using an auto-termination policy. Creates or updates an auto-termination policy for an Amazon EMR cluster. An auto-termination policy defines the amount of idle time in seconds after which a cluster automatically terminates. For alternative cluster termination options, see Control cluster termination.
Auto-termination is supported in Amazon EMR releases 5.30.0 and 6.1.0 and later. For more information, see Using an auto-termination policy. Creates or updates an auto-termination policy for an Amazon EMR cluster. An auto-termination policy defines the amount of idle time in seconds after which a cluster automatically terminates. For alternative cluster termination options, see Control cluster termination.
module PutBlockPublicAccessConfigurationInput =
Awso_emr.Values.PutBlockPublicAccessConfigurationInputCreates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
module PutBlockPublicAccessConfigurationOutput =
Awso_emr.Values.PutBlockPublicAccessConfigurationOutputCreates or updates an Amazon EMR block public access configuration for your Amazon Web Services account in the current Region. For more information see Configure Block Public Access for Amazon EMR in the Amazon EMR Management Guide.
Creates or updates a managed scaling policy for an Amazon EMR cluster. The managed scaling policy defines the limits for resources, such as Amazon EC2 instances that can be added or terminated from a cluster. The policy only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
Creates or updates a managed scaling policy for an Amazon EMR cluster. The managed scaling policy defines the limits for resources, such as Amazon EC2 instances that can be added or terminated from a cluster. The policy only applies to the core and task nodes. The master node cannot be scaled after initial configuration.
Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.
Removes an automatic scaling policy from a specified instance group within an Amazon EMR cluster.
Removes an auto-termination policy from an Amazon EMR cluster.
Removes an auto-termination policy from an Amazon EMR cluster.
Removes a managed scaling policy from a specified Amazon EMR cluster.
Removes a managed scaling policy from a specified Amazon EMR cluster.
This input identifies an Amazon EMR resource and a list of tags to remove.
This output indicates the result of removing tags from the resource.
Input to the RunJobFlow operation.
The result of the RunJobFlow operation.
module SetKeepJobFlowAliveWhenNoStepsInput =
Awso_emr.Values.SetKeepJobFlowAliveWhenNoStepsInputYou can use the SetKeepJobFlowAliveWhenNoSteps to configure a cluster (job flow) to terminate after the step execution, i.e., all your steps are executed. If you want a transient cluster that shuts down after the last of the current executing steps are completed, you can configure SetKeepJobFlowAliveWhenNoSteps to false. If you want a long running cluster, configure SetKeepJobFlowAliveWhenNoSteps to true. For more information, see Managing Cluster Termination in the Amazon EMR Management Guide.
The input argument to the TerminationProtection operation.
Specify whether to enable unhealthy node replacement, which lets Amazon EMR gracefully replace core nodes on a cluster if any nodes become unhealthy. For example, a node becomes unhealthy if disk usage is above 90%. If unhealthy node replacement is on and TerminationProtected are off, Amazon EMR immediately terminates the unhealthy core nodes. To use unhealthy node replacement and retain unhealthy core nodes, use to turn on termination protection. In such cases, Amazon EMR adds the unhealthy nodes to a denylist, reducing job interruptions and failures. If unhealthy node replacement is on, Amazon EMR notifies YARN and other applications on the cluster to stop scheduling tasks with these nodes, moves the data, and then terminates the nodes. For more information, see graceful node replacement in the Amazon EMR Management Guide.
The input to the SetVisibleToAllUsers action.
Starts a notebook execution.
Starts a notebook execution.
Stops a notebook execution.
Input to the TerminateJobFlows operation.
Updates an Amazon EMR Studio configuration, including attributes such as name, description, and subnets.
Updates the session policy attached to the user or group for the specified Amazon EMR Studio.