/*
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
* A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file. This file is distributed
* on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
* express or implied. See the License for the specific language governing
* permissions and limitations under the License.
*/
/*
* Do not modify this file. This file is generated from the elasticmapreduce-2009-03-31.normal.json service model.
*/
using System;
using System.Runtime.ExceptionServices;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Net;
using Amazon.ElasticMapReduce.Model;
using Amazon.ElasticMapReduce.Model.Internal.MarshallTransformations;
using Amazon.ElasticMapReduce.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.ElasticMapReduce
{
///
/// Implementation for accessing ElasticMapReduce
///
/// Amazon EMR is a web service that makes it easier to process large amounts of data
/// efficiently. Amazon EMR uses Hadoop processing combined with several Amazon Web Services
/// services to do tasks such as web indexing, data mining, log file analysis, machine
/// learning, scientific simulation, and data warehouse management.
///
public partial class AmazonElasticMapReduceClient : AmazonServiceClient, IAmazonElasticMapReduce
{
private static IServiceMetadata serviceMetadata = new AmazonElasticMapReduceMetadata();
private IElasticMapReducePaginatorFactory _paginators;
///
/// Paginators for the service
///
public IElasticMapReducePaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new ElasticMapReducePaginatorFactory(this);
}
return this._paginators;
}
}
#region Constructors
///
/// Constructs AmazonElasticMapReduceClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
public AmazonElasticMapReduceClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonElasticMapReduceConfig()) { }
///
/// Constructs AmazonElasticMapReduceClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The region to connect.
public AmazonElasticMapReduceClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonElasticMapReduceConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonElasticMapReduceClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The AmazonElasticMapReduceClient Configuration Object
public AmazonElasticMapReduceClient(AmazonElasticMapReduceConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonElasticMapReduceClient with AWS Credentials
///
/// AWS Credentials
public AmazonElasticMapReduceClient(AWSCredentials credentials)
: this(credentials, new AmazonElasticMapReduceConfig())
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonElasticMapReduceClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonElasticMapReduceConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Credentials and an
/// AmazonElasticMapReduceClient Configuration object.
///
/// AWS Credentials
/// The AmazonElasticMapReduceClient Configuration Object
public AmazonElasticMapReduceClient(AWSCredentials credentials, AmazonElasticMapReduceConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonElasticMapReduceConfig())
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonElasticMapReduceConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonElasticMapReduceClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonElasticMapReduceClient Configuration Object
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonElasticMapReduceConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonElasticMapReduceConfig())
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The region to connect.
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonElasticMapReduceConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonElasticMapReduceClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonElasticMapReduceClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonElasticMapReduceClient Configuration Object
public AmazonElasticMapReduceClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonElasticMapReduceConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig)
{
}
#endregion
#region Overrides
///
/// Creates the signer for the service.
///
protected override AbstractAWSSigner CreateSigner()
{
return new AWS4Signer();
}
///
/// Customize the pipeline
///
///
protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline)
{
pipeline.RemoveHandler();
pipeline.AddHandlerAfter(new AmazonElasticMapReduceEndpointResolver());
}
///
/// Capture metadata for the service.
///
protected override IServiceMetadata ServiceMetadata
{
get
{
return serviceMetadata;
}
}
#endregion
#region Dispose
///
/// Disposes the service client.
///
protected override void Dispose(bool disposing)
{
base.Dispose(disposing);
}
#endregion
#region AddInstanceFleet
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the AddInstanceFleet service method.
///
/// The response from the AddInstanceFleet service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for AddInstanceFleet Operation
public virtual AddInstanceFleetResponse AddInstanceFleet(AddInstanceFleetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddInstanceFleetRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddInstanceFleetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the AddInstanceFleet service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddInstanceFleet service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for AddInstanceFleet Operation
public virtual Task AddInstanceFleetAsync(AddInstanceFleetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddInstanceFleetRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddInstanceFleetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddInstanceGroups
///
/// Adds one or more instance groups to a running cluster.
///
/// Container for the necessary parameters to execute the AddInstanceGroups service method.
///
/// The response from the AddInstanceGroups service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for AddInstanceGroups Operation
public virtual AddInstanceGroupsResponse AddInstanceGroups(AddInstanceGroupsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddInstanceGroupsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds one or more instance groups to a running cluster.
///
/// Container for the necessary parameters to execute the AddInstanceGroups service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddInstanceGroups service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for AddInstanceGroups Operation
public virtual Task AddInstanceGroupsAsync(AddInstanceGroupsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddInstanceGroupsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddJobFlowSteps
///
/// AddJobFlowSteps adds new steps to a running cluster. A maximum of 256 steps are allowed
/// in each job flow.
///
///
///
/// If your cluster is long-running (such as a Hive data warehouse) or complex, you may
/// require more than 256 steps to process your data. You can bypass the 256-step limitation
/// in various ways, including using SSH to connect to the master node and submitting
/// queries directly to the software running on the master node, such as Hive and Hadoop.
///
///
///
/// A step specifies the location of a JAR file stored either on the master node of the
/// cluster or in Amazon S3. Each step is performed by the main function of the main class
/// of the JAR file. The main class can be specified either in the manifest of the JAR
/// or by using the MainFunction parameter of the step.
///
///
///
/// Amazon EMR executes each step in the order listed. For a step to be considered complete,
/// the main function must exit with a zero exit code and all Hadoop jobs started while
/// the step was running must have completed and run successfully.
///
///
///
/// You can only add steps to a cluster that is in one of the following states: STARTING,
/// BOOTSTRAPPING, RUNNING, or WAITING.
///
///
///
/// The string values passed into HadoopJarStep
object cannot exceed a total
/// of 10240 characters.
///
///
///
/// Container for the necessary parameters to execute the AddJobFlowSteps service method.
///
/// The response from the AddJobFlowSteps service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for AddJobFlowSteps Operation
public virtual AddJobFlowStepsResponse AddJobFlowSteps(AddJobFlowStepsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddJobFlowStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddJobFlowStepsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// AddJobFlowSteps adds new steps to a running cluster. A maximum of 256 steps are allowed
/// in each job flow.
///
///
///
/// If your cluster is long-running (such as a Hive data warehouse) or complex, you may
/// require more than 256 steps to process your data. You can bypass the 256-step limitation
/// in various ways, including using SSH to connect to the master node and submitting
/// queries directly to the software running on the master node, such as Hive and Hadoop.
///
///
///
/// A step specifies the location of a JAR file stored either on the master node of the
/// cluster or in Amazon S3. Each step is performed by the main function of the main class
/// of the JAR file. The main class can be specified either in the manifest of the JAR
/// or by using the MainFunction parameter of the step.
///
///
///
/// Amazon EMR executes each step in the order listed. For a step to be considered complete,
/// the main function must exit with a zero exit code and all Hadoop jobs started while
/// the step was running must have completed and run successfully.
///
///
///
/// You can only add steps to a cluster that is in one of the following states: STARTING,
/// BOOTSTRAPPING, RUNNING, or WAITING.
///
///
///
/// The string values passed into HadoopJarStep
object cannot exceed a total
/// of 10240 characters.
///
///
///
/// Container for the necessary parameters to execute the AddJobFlowSteps service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddJobFlowSteps service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for AddJobFlowSteps Operation
public virtual Task AddJobFlowStepsAsync(AddJobFlowStepsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddJobFlowStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddJobFlowStepsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddTags
///
/// Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio. Tags
/// make it easier to associate resources in various ways, such as grouping clusters to
/// track your Amazon EMR resource allocation costs. For more information, see Tag
/// Clusters.
///
/// Container for the necessary parameters to execute the AddTags service method.
///
/// The response from the AddTags service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for AddTags Operation
public virtual AddTagsResponse AddTags(AddTagsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddTagsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddTagsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds tags to an Amazon EMR resource, such as a cluster or an Amazon EMR Studio. Tags
/// make it easier to associate resources in various ways, such as grouping clusters to
/// track your Amazon EMR resource allocation costs. For more information, see Tag
/// Clusters.
///
/// Container for the necessary parameters to execute the AddTags service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddTags service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for AddTags Operation
public virtual Task AddTagsAsync(AddTagsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddTagsRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddTagsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CancelSteps
///
/// Cancels a pending step or steps in a running cluster. Available only in Amazon EMR
/// versions 4.8.0 and later, excluding version 5.0.0. A maximum of 256 steps are allowed
/// in each CancelSteps request. CancelSteps is idempotent but asynchronous; it does not
/// guarantee that a step will be canceled, even if the request is successfully submitted.
/// When you use Amazon EMR releases 5.28.0 and later, you can cancel steps that are in
/// a PENDING
or RUNNING
state. In earlier versions of Amazon
/// EMR, you can only cancel steps that are in a PENDING
state.
///
/// Container for the necessary parameters to execute the CancelSteps service method.
///
/// The response from the CancelSteps service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CancelSteps Operation
public virtual CancelStepsResponse CancelSteps(CancelStepsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelStepsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Cancels a pending step or steps in a running cluster. Available only in Amazon EMR
/// versions 4.8.0 and later, excluding version 5.0.0. A maximum of 256 steps are allowed
/// in each CancelSteps request. CancelSteps is idempotent but asynchronous; it does not
/// guarantee that a step will be canceled, even if the request is successfully submitted.
/// When you use Amazon EMR releases 5.28.0 and later, you can cancel steps that are in
/// a PENDING
or RUNNING
state. In earlier versions of Amazon
/// EMR, you can only cancel steps that are in a PENDING
state.
///
/// Container for the necessary parameters to execute the CancelSteps service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CancelSteps service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CancelSteps Operation
public virtual Task CancelStepsAsync(CancelStepsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelStepsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateSecurityConfiguration
///
/// Creates a security configuration, which is stored in the service and can be specified
/// when a cluster is created.
///
/// Container for the necessary parameters to execute the CreateSecurityConfiguration service method.
///
/// The response from the CreateSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateSecurityConfiguration Operation
public virtual CreateSecurityConfigurationResponse CreateSecurityConfiguration(CreateSecurityConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateSecurityConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a security configuration, which is stored in the service and can be specified
/// when a cluster is created.
///
/// Container for the necessary parameters to execute the CreateSecurityConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateSecurityConfiguration Operation
public virtual Task CreateSecurityConfigurationAsync(CreateSecurityConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateSecurityConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateStudio
///
/// Creates a new Amazon EMR Studio.
///
/// Container for the necessary parameters to execute the CreateStudio service method.
///
/// The response from the CreateStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateStudio Operation
public virtual CreateStudioResponse CreateStudio(CreateStudioRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateStudioResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a new Amazon EMR Studio.
///
/// Container for the necessary parameters to execute the CreateStudio service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateStudio Operation
public virtual Task CreateStudioAsync(CreateStudioRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateStudioResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateStudioSessionMapping
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateStudioSessionMapping service method.
///
/// The response from the CreateStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateStudioSessionMapping Operation
public virtual CreateStudioSessionMappingResponse CreateStudioSessionMapping(CreateStudioSessionMappingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateStudioSessionMappingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the CreateStudioSessionMapping service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for CreateStudioSessionMapping Operation
public virtual Task CreateStudioSessionMappingAsync(CreateStudioSessionMappingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateStudioSessionMappingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteSecurityConfiguration
///
/// Deletes a security configuration.
///
/// Container for the necessary parameters to execute the DeleteSecurityConfiguration service method.
///
/// The response from the DeleteSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteSecurityConfiguration Operation
public virtual DeleteSecurityConfigurationResponse DeleteSecurityConfiguration(DeleteSecurityConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSecurityConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a security configuration.
///
/// Container for the necessary parameters to execute the DeleteSecurityConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteSecurityConfiguration Operation
public virtual Task DeleteSecurityConfigurationAsync(DeleteSecurityConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSecurityConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteStudio
///
/// Removes an Amazon EMR Studio from the Studio metadata store.
///
/// Container for the necessary parameters to execute the DeleteStudio service method.
///
/// The response from the DeleteStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteStudio Operation
public virtual DeleteStudioResponse DeleteStudio(DeleteStudioRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteStudioResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes an Amazon EMR Studio from the Studio metadata store.
///
/// Container for the necessary parameters to execute the DeleteStudio service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteStudio Operation
public virtual Task DeleteStudioAsync(DeleteStudioRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteStudioResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteStudioSessionMapping
///
/// Removes a user or group from an Amazon EMR Studio.
///
/// Container for the necessary parameters to execute the DeleteStudioSessionMapping service method.
///
/// The response from the DeleteStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteStudioSessionMapping Operation
public virtual DeleteStudioSessionMappingResponse DeleteStudioSessionMapping(DeleteStudioSessionMappingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteStudioSessionMappingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes a user or group from an Amazon EMR Studio.
///
/// Container for the necessary parameters to execute the DeleteStudioSessionMapping service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DeleteStudioSessionMapping Operation
public virtual Task DeleteStudioSessionMappingAsync(DeleteStudioSessionMappingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteStudioSessionMappingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeCluster
///
/// Provides cluster-level details including status, hardware and software configuration,
/// VPC settings, and so on.
///
///
/// The response from the DescribeCluster service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeCluster Operation
public virtual DescribeClusterResponse DescribeCluster()
{
return DescribeCluster(new DescribeClusterRequest());
}
///
/// Provides cluster-level details including status, hardware and software configuration,
/// VPC settings, and so on.
///
/// Container for the necessary parameters to execute the DescribeCluster service method.
///
/// The response from the DescribeCluster service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeCluster Operation
public virtual DescribeClusterResponse DescribeCluster(DescribeClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides cluster-level details including status, hardware and software configuration,
/// VPC settings, and so on.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeCluster service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeCluster Operation
public virtual Task DescribeClusterAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return DescribeClusterAsync(new DescribeClusterRequest(), cancellationToken);
}
///
/// Provides cluster-level details including status, hardware and software configuration,
/// VPC settings, and so on.
///
/// Container for the necessary parameters to execute the DescribeCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeCluster service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeCluster Operation
public virtual Task DescribeClusterAsync(DescribeClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeJobFlows
///
/// This API is no longer supported and will eventually be removed. We recommend you use
/// ListClusters, DescribeCluster, ListSteps, ListInstanceGroups
/// and ListBootstrapActions instead.
///
///
///
/// DescribeJobFlows returns a list of job flows that match all of the supplied parameters.
/// The parameters can include a list of job flow IDs, job flow states, and restrictions
/// on job flow creation date and time.
///
///
///
/// Regardless of supplied parameters, only job flows created within the last two months
/// are returned.
///
///
///
/// If no parameters are supplied, then job flows matching either of the following criteria
/// are returned:
///
/// -
///
/// Job flows created and completed in the last two weeks
///
///
-
///
/// Job flows created within the last two months that are in one of the following states:
///
RUNNING
, WAITING
, SHUTTING_DOWN
, STARTING
///
///
///
///
/// Amazon EMR can return a maximum of 512 job flow descriptions.
///
///
///
/// The response from the DescribeJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for DescribeJobFlows Operation
[Obsolete("This API is deprecated and will eventually be removed. We recommend that you use ListClusters, DescribeCluster, ListSteps, ListInstanceGroups and ListBootstrapActions instead.")]
public virtual DescribeJobFlowsResponse DescribeJobFlows()
{
return DescribeJobFlows(new DescribeJobFlowsRequest());
}
///
/// This API is no longer supported and will eventually be removed. We recommend you use
/// ListClusters, DescribeCluster, ListSteps, ListInstanceGroups
/// and ListBootstrapActions instead.
///
///
///
/// DescribeJobFlows returns a list of job flows that match all of the supplied parameters.
/// The parameters can include a list of job flow IDs, job flow states, and restrictions
/// on job flow creation date and time.
///
///
///
/// Regardless of supplied parameters, only job flows created within the last two months
/// are returned.
///
///
///
/// If no parameters are supplied, then job flows matching either of the following criteria
/// are returned:
///
/// -
///
/// Job flows created and completed in the last two weeks
///
///
-
///
/// Job flows created within the last two months that are in one of the following states:
///
RUNNING
, WAITING
, SHUTTING_DOWN
, STARTING
///
///
///
///
/// Amazon EMR can return a maximum of 512 job flow descriptions.
///
///
/// Container for the necessary parameters to execute the DescribeJobFlows service method.
///
/// The response from the DescribeJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for DescribeJobFlows Operation
[Obsolete("This API is deprecated and will eventually be removed. We recommend that you use ListClusters, DescribeCluster, ListSteps, ListInstanceGroups and ListBootstrapActions instead.")]
public virtual DescribeJobFlowsResponse DescribeJobFlows(DescribeJobFlowsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobFlowsRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobFlowsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// This API is no longer supported and will eventually be removed. We recommend you use
/// ListClusters, DescribeCluster, ListSteps, ListInstanceGroups
/// and ListBootstrapActions instead.
///
///
///
/// DescribeJobFlows returns a list of job flows that match all of the supplied parameters.
/// The parameters can include a list of job flow IDs, job flow states, and restrictions
/// on job flow creation date and time.
///
///
///
/// Regardless of supplied parameters, only job flows created within the last two months
/// are returned.
///
///
///
/// If no parameters are supplied, then job flows matching either of the following criteria
/// are returned:
///
/// -
///
/// Job flows created and completed in the last two weeks
///
///
-
///
/// Job flows created within the last two months that are in one of the following states:
///
RUNNING
, WAITING
, SHUTTING_DOWN
, STARTING
///
///
///
///
/// Amazon EMR can return a maximum of 512 job flow descriptions.
///
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for DescribeJobFlows Operation
[Obsolete("This API is deprecated and will eventually be removed. We recommend that you use ListClusters, DescribeCluster, ListSteps, ListInstanceGroups and ListBootstrapActions instead.")]
public virtual Task DescribeJobFlowsAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return DescribeJobFlowsAsync(new DescribeJobFlowsRequest(), cancellationToken);
}
///
/// This API is no longer supported and will eventually be removed. We recommend you use
/// ListClusters, DescribeCluster, ListSteps, ListInstanceGroups
/// and ListBootstrapActions instead.
///
///
///
/// DescribeJobFlows returns a list of job flows that match all of the supplied parameters.
/// The parameters can include a list of job flow IDs, job flow states, and restrictions
/// on job flow creation date and time.
///
///
///
/// Regardless of supplied parameters, only job flows created within the last two months
/// are returned.
///
///
///
/// If no parameters are supplied, then job flows matching either of the following criteria
/// are returned:
///
/// -
///
/// Job flows created and completed in the last two weeks
///
///
-
///
/// Job flows created within the last two months that are in one of the following states:
///
RUNNING
, WAITING
, SHUTTING_DOWN
, STARTING
///
///
///
///
/// Amazon EMR can return a maximum of 512 job flow descriptions.
///
///
/// Container for the necessary parameters to execute the DescribeJobFlows service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for DescribeJobFlows Operation
[Obsolete("This API is deprecated and will eventually be removed. We recommend that you use ListClusters, DescribeCluster, ListSteps, ListInstanceGroups and ListBootstrapActions instead.")]
public virtual Task DescribeJobFlowsAsync(DescribeJobFlowsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobFlowsRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobFlowsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeNotebookExecution
///
/// Provides details of a notebook execution.
///
/// Container for the necessary parameters to execute the DescribeNotebookExecution service method.
///
/// The response from the DescribeNotebookExecution service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeNotebookExecution Operation
public virtual DescribeNotebookExecutionResponse DescribeNotebookExecution(DescribeNotebookExecutionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeNotebookExecutionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides details of a notebook execution.
///
/// Container for the necessary parameters to execute the DescribeNotebookExecution service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeNotebookExecution service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeNotebookExecution Operation
public virtual Task DescribeNotebookExecutionAsync(DescribeNotebookExecutionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeNotebookExecutionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeReleaseLabel
///
/// 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.
///
/// Container for the necessary parameters to execute the DescribeReleaseLabel service method.
///
/// The response from the DescribeReleaseLabel service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeReleaseLabel Operation
public virtual DescribeReleaseLabelResponse DescribeReleaseLabel(DescribeReleaseLabelRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeReleaseLabelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeReleaseLabelResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the DescribeReleaseLabel service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeReleaseLabel service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeReleaseLabel Operation
public virtual Task DescribeReleaseLabelAsync(DescribeReleaseLabelRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeReleaseLabelRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeReleaseLabelResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeSecurityConfiguration
///
/// Provides the details of a security configuration by returning the configuration JSON.
///
/// Container for the necessary parameters to execute the DescribeSecurityConfiguration service method.
///
/// The response from the DescribeSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeSecurityConfiguration Operation
public virtual DescribeSecurityConfigurationResponse DescribeSecurityConfiguration(DescribeSecurityConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeSecurityConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides the details of a security configuration by returning the configuration JSON.
///
/// Container for the necessary parameters to execute the DescribeSecurityConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeSecurityConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeSecurityConfiguration Operation
public virtual Task DescribeSecurityConfigurationAsync(DescribeSecurityConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeSecurityConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeSecurityConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeStep
///
/// Provides more detail about the cluster step.
///
///
/// The response from the DescribeStep service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStep Operation
public virtual DescribeStepResponse DescribeStep()
{
return DescribeStep(new DescribeStepRequest());
}
///
/// Provides more detail about the cluster step.
///
/// Container for the necessary parameters to execute the DescribeStep service method.
///
/// The response from the DescribeStep service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStep Operation
public virtual DescribeStepResponse DescribeStep(DescribeStepRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeStepRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeStepResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides more detail about the cluster step.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeStep service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStep Operation
public virtual Task DescribeStepAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return DescribeStepAsync(new DescribeStepRequest(), cancellationToken);
}
///
/// Provides more detail about the cluster step.
///
/// Container for the necessary parameters to execute the DescribeStep service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeStep service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStep Operation
public virtual Task DescribeStepAsync(DescribeStepRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeStepRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeStepResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeStudio
///
/// Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio
/// access URL, and so on.
///
/// Container for the necessary parameters to execute the DescribeStudio service method.
///
/// The response from the DescribeStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStudio Operation
public virtual DescribeStudioResponse DescribeStudio(DescribeStudioRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeStudioResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns details for the specified Amazon EMR Studio including ID, Name, VPC, Studio
/// access URL, and so on.
///
/// Container for the necessary parameters to execute the DescribeStudio service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for DescribeStudio Operation
public virtual Task DescribeStudioAsync(DescribeStudioRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeStudioResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetAutoTerminationPolicy
///
/// Returns the auto-termination policy for an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the GetAutoTerminationPolicy service method.
///
/// The response from the GetAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for GetAutoTerminationPolicy Operation
public virtual GetAutoTerminationPolicyResponse GetAutoTerminationPolicy(GetAutoTerminationPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetAutoTerminationPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns the auto-termination policy for an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the GetAutoTerminationPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for GetAutoTerminationPolicy Operation
public virtual Task GetAutoTerminationPolicyAsync(GetAutoTerminationPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetAutoTerminationPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetBlockPublicAccessConfiguration
///
/// Returns 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.
///
/// Container for the necessary parameters to execute the GetBlockPublicAccessConfiguration service method.
///
/// The response from the GetBlockPublicAccessConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetBlockPublicAccessConfiguration Operation
public virtual GetBlockPublicAccessConfigurationResponse GetBlockPublicAccessConfiguration(GetBlockPublicAccessConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetBlockPublicAccessConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetBlockPublicAccessConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns 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.
///
/// Container for the necessary parameters to execute the GetBlockPublicAccessConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetBlockPublicAccessConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetBlockPublicAccessConfiguration Operation
public virtual Task GetBlockPublicAccessConfigurationAsync(GetBlockPublicAccessConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetBlockPublicAccessConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetBlockPublicAccessConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetClusterSessionCredentials
///
/// 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.
///
/// Container for the necessary parameters to execute the GetClusterSessionCredentials service method.
///
/// The response from the GetClusterSessionCredentials service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetClusterSessionCredentials Operation
public virtual GetClusterSessionCredentialsResponse GetClusterSessionCredentials(GetClusterSessionCredentialsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetClusterSessionCredentialsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetClusterSessionCredentialsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the GetClusterSessionCredentials service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetClusterSessionCredentials service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetClusterSessionCredentials Operation
public virtual Task GetClusterSessionCredentialsAsync(GetClusterSessionCredentialsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetClusterSessionCredentialsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetClusterSessionCredentialsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetManagedScalingPolicy
///
/// Fetches the attached managed scaling policy for an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the GetManagedScalingPolicy service method.
///
/// The response from the GetManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for GetManagedScalingPolicy Operation
public virtual GetManagedScalingPolicyResponse GetManagedScalingPolicy(GetManagedScalingPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetManagedScalingPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Fetches the attached managed scaling policy for an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the GetManagedScalingPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for GetManagedScalingPolicy Operation
public virtual Task GetManagedScalingPolicyAsync(GetManagedScalingPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetManagedScalingPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetStudioSessionMapping
///
/// Fetches mapping details for the specified Amazon EMR Studio and identity (user or
/// group).
///
/// Container for the necessary parameters to execute the GetStudioSessionMapping service method.
///
/// The response from the GetStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetStudioSessionMapping Operation
public virtual GetStudioSessionMappingResponse GetStudioSessionMapping(GetStudioSessionMappingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetStudioSessionMappingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Fetches mapping details for the specified Amazon EMR Studio and identity (user or
/// group).
///
/// Container for the necessary parameters to execute the GetStudioSessionMapping service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for GetStudioSessionMapping Operation
public virtual Task GetStudioSessionMappingAsync(GetStudioSessionMappingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetStudioSessionMappingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListBootstrapActions
///
/// Provides information about the bootstrap actions associated with a cluster.
///
///
/// The response from the ListBootstrapActions service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListBootstrapActions Operation
public virtual ListBootstrapActionsResponse ListBootstrapActions()
{
return ListBootstrapActions(new ListBootstrapActionsRequest());
}
///
/// Provides information about the bootstrap actions associated with a cluster.
///
/// Container for the necessary parameters to execute the ListBootstrapActions service method.
///
/// The response from the ListBootstrapActions service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListBootstrapActions Operation
public virtual ListBootstrapActionsResponse ListBootstrapActions(ListBootstrapActionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListBootstrapActionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListBootstrapActionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides information about the bootstrap actions associated with a cluster.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListBootstrapActions service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListBootstrapActions Operation
public virtual Task ListBootstrapActionsAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return ListBootstrapActionsAsync(new ListBootstrapActionsRequest(), cancellationToken);
}
///
/// Provides information about the bootstrap actions associated with a cluster.
///
/// Container for the necessary parameters to execute the ListBootstrapActions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListBootstrapActions service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListBootstrapActions Operation
public virtual Task ListBootstrapActionsAsync(ListBootstrapActionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListBootstrapActionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListBootstrapActionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListClusters
///
/// Provides the status of all clusters visible to this Amazon Web Services account. Allows
/// you to filter the list of clusters based on certain criteria; for example, filtering
/// by cluster creation date and time or by status. This call returns a maximum of 50
/// clusters in unsorted order per call, but returns a marker to track the paging of the
/// cluster list across multiple ListClusters calls.
///
///
/// The response from the ListClusters service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListClusters Operation
public virtual ListClustersResponse ListClusters()
{
return ListClusters(new ListClustersRequest());
}
///
/// Provides the status of all clusters visible to this Amazon Web Services account. Allows
/// you to filter the list of clusters based on certain criteria; for example, filtering
/// by cluster creation date and time or by status. This call returns a maximum of 50
/// clusters in unsorted order per call, but returns a marker to track the paging of the
/// cluster list across multiple ListClusters calls.
///
/// Container for the necessary parameters to execute the ListClusters service method.
///
/// The response from the ListClusters service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListClusters Operation
public virtual ListClustersResponse ListClusters(ListClustersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides the status of all clusters visible to this Amazon Web Services account. Allows
/// you to filter the list of clusters based on certain criteria; for example, filtering
/// by cluster creation date and time or by status. This call returns a maximum of 50
/// clusters in unsorted order per call, but returns a marker to track the paging of the
/// cluster list across multiple ListClusters calls.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClusters service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListClusters Operation
public virtual Task ListClustersAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return ListClustersAsync(new ListClustersRequest(), cancellationToken);
}
///
/// Provides the status of all clusters visible to this Amazon Web Services account. Allows
/// you to filter the list of clusters based on certain criteria; for example, filtering
/// by cluster creation date and time or by status. This call returns a maximum of 50
/// clusters in unsorted order per call, but returns a marker to track the paging of the
/// cluster list across multiple ListClusters calls.
///
/// Container for the necessary parameters to execute the ListClusters service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListClusters service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListClusters Operation
public virtual Task ListClustersAsync(ListClustersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListClustersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListInstanceFleets
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the ListInstanceFleets service method.
///
/// The response from the ListInstanceFleets service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceFleets Operation
public virtual ListInstanceFleetsResponse ListInstanceFleets(ListInstanceFleetsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstanceFleetsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstanceFleetsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the ListInstanceFleets service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListInstanceFleets service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceFleets Operation
public virtual Task ListInstanceFleetsAsync(ListInstanceFleetsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstanceFleetsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstanceFleetsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListInstanceGroups
///
/// Provides all available details about the instance groups in a cluster.
///
///
/// The response from the ListInstanceGroups service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceGroups Operation
public virtual ListInstanceGroupsResponse ListInstanceGroups()
{
return ListInstanceGroups(new ListInstanceGroupsRequest());
}
///
/// Provides all available details about the instance groups in a cluster.
///
/// Container for the necessary parameters to execute the ListInstanceGroups service method.
///
/// The response from the ListInstanceGroups service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceGroups Operation
public virtual ListInstanceGroupsResponse ListInstanceGroups(ListInstanceGroupsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstanceGroupsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides all available details about the instance groups in a cluster.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListInstanceGroups service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceGroups Operation
public virtual Task ListInstanceGroupsAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return ListInstanceGroupsAsync(new ListInstanceGroupsRequest(), cancellationToken);
}
///
/// Provides all available details about the instance groups in a cluster.
///
/// Container for the necessary parameters to execute the ListInstanceGroups service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListInstanceGroups service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstanceGroups Operation
public virtual Task ListInstanceGroupsAsync(ListInstanceGroupsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstanceGroupsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListInstances
///
/// Provides information for all active Amazon EC2 instances and Amazon EC2 instances
/// terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in
/// any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING,
/// BOOTSTRAPPING, RUNNING.
///
///
/// The response from the ListInstances service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstances Operation
public virtual ListInstancesResponse ListInstances()
{
return ListInstances(new ListInstancesRequest());
}
///
/// Provides information for all active Amazon EC2 instances and Amazon EC2 instances
/// terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in
/// any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING,
/// BOOTSTRAPPING, RUNNING.
///
/// Container for the necessary parameters to execute the ListInstances service method.
///
/// The response from the ListInstances service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstances Operation
public virtual ListInstancesResponse ListInstances(ListInstancesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstancesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstancesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides information for all active Amazon EC2 instances and Amazon EC2 instances
/// terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in
/// any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING,
/// BOOTSTRAPPING, RUNNING.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListInstances service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstances Operation
public virtual Task ListInstancesAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return ListInstancesAsync(new ListInstancesRequest(), cancellationToken);
}
///
/// Provides information for all active Amazon EC2 instances and Amazon EC2 instances
/// terminated in the last 30 days, up to a maximum of 2,000. Amazon EC2 instances in
/// any of the following states are considered active: AWAITING_FULFILLMENT, PROVISIONING,
/// BOOTSTRAPPING, RUNNING.
///
/// Container for the necessary parameters to execute the ListInstances service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListInstances service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListInstances Operation
public virtual Task ListInstancesAsync(ListInstancesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListInstancesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListInstancesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListNotebookExecutions
///
/// 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.
///
/// Container for the necessary parameters to execute the ListNotebookExecutions service method.
///
/// The response from the ListNotebookExecutions service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListNotebookExecutions Operation
public virtual ListNotebookExecutionsResponse ListNotebookExecutions(ListNotebookExecutionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListNotebookExecutionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListNotebookExecutionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the ListNotebookExecutions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListNotebookExecutions service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListNotebookExecutions Operation
public virtual Task ListNotebookExecutionsAsync(ListNotebookExecutionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListNotebookExecutionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListNotebookExecutionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListReleaseLabels
///
/// Retrieves release labels of Amazon EMR services in the Region where the API is called.
///
/// Container for the necessary parameters to execute the ListReleaseLabels service method.
///
/// The response from the ListReleaseLabels service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListReleaseLabels Operation
public virtual ListReleaseLabelsResponse ListReleaseLabels(ListReleaseLabelsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListReleaseLabelsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListReleaseLabelsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieves release labels of Amazon EMR services in the Region where the API is called.
///
/// Container for the necessary parameters to execute the ListReleaseLabels service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListReleaseLabels service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListReleaseLabels Operation
public virtual Task ListReleaseLabelsAsync(ListReleaseLabelsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListReleaseLabelsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListReleaseLabelsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListSecurityConfigurations
///
/// 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.
///
/// Container for the necessary parameters to execute the ListSecurityConfigurations service method.
///
/// The response from the ListSecurityConfigurations service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSecurityConfigurations Operation
public virtual ListSecurityConfigurationsResponse ListSecurityConfigurations(ListSecurityConfigurationsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSecurityConfigurationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSecurityConfigurationsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the ListSecurityConfigurations service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSecurityConfigurations service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSecurityConfigurations Operation
public virtual Task ListSecurityConfigurationsAsync(ListSecurityConfigurationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSecurityConfigurationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSecurityConfigurationsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListSteps
///
/// Provides a list of steps for the cluster in reverse order unless you specify stepIds
/// with the request or filter by StepStates
. You can specify a maximum of
/// 10 stepIDs
. The CLI automatically paginates results to return a list
/// greater than 50 steps. To return more than 50 steps using the CLI, specify a Marker
,
/// which is a pagination token that indicates the next set of steps to retrieve.
///
///
/// The response from the ListSteps service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSteps Operation
public virtual ListStepsResponse ListSteps()
{
return ListSteps(new ListStepsRequest());
}
///
/// Provides a list of steps for the cluster in reverse order unless you specify stepIds
/// with the request or filter by StepStates
. You can specify a maximum of
/// 10 stepIDs
. The CLI automatically paginates results to return a list
/// greater than 50 steps. To return more than 50 steps using the CLI, specify a Marker
,
/// which is a pagination token that indicates the next set of steps to retrieve.
///
/// Container for the necessary parameters to execute the ListSteps service method.
///
/// The response from the ListSteps service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSteps Operation
public virtual ListStepsResponse ListSteps(ListStepsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStepsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides a list of steps for the cluster in reverse order unless you specify stepIds
/// with the request or filter by StepStates
. You can specify a maximum of
/// 10 stepIDs
. The CLI automatically paginates results to return a list
/// greater than 50 steps. To return more than 50 steps using the CLI, specify a Marker
,
/// which is a pagination token that indicates the next set of steps to retrieve.
///
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSteps service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSteps Operation
public virtual Task ListStepsAsync(System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
return ListStepsAsync(new ListStepsRequest(), cancellationToken);
}
///
/// Provides a list of steps for the cluster in reverse order unless you specify stepIds
/// with the request or filter by StepStates
. You can specify a maximum of
/// 10 stepIDs
. The CLI automatically paginates results to return a list
/// greater than 50 steps. To return more than 50 steps using the CLI, specify a Marker
,
/// which is a pagination token that indicates the next set of steps to retrieve.
///
/// Container for the necessary parameters to execute the ListSteps service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSteps service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSteps Operation
public virtual Task ListStepsAsync(ListStepsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStepsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStepsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListStudios
///
/// 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.
///
/// Container for the necessary parameters to execute the ListStudios service method.
///
/// The response from the ListStudios service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListStudios Operation
public virtual ListStudiosResponse ListStudios(ListStudiosRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStudiosRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStudiosResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the ListStudios service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListStudios service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListStudios Operation
public virtual Task ListStudiosAsync(ListStudiosRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStudiosRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStudiosResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListStudioSessionMappings
///
/// Returns a list of all user or group session mappings for the Amazon EMR Studio specified
/// by StudioId
.
///
/// Container for the necessary parameters to execute the ListStudioSessionMappings service method.
///
/// The response from the ListStudioSessionMappings service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListStudioSessionMappings Operation
public virtual ListStudioSessionMappingsResponse ListStudioSessionMappings(ListStudioSessionMappingsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStudioSessionMappingsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStudioSessionMappingsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of all user or group session mappings for the Amazon EMR Studio specified
/// by StudioId
.
///
/// Container for the necessary parameters to execute the ListStudioSessionMappings service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListStudioSessionMappings service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListStudioSessionMappings Operation
public virtual Task ListStudioSessionMappingsAsync(ListStudioSessionMappingsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListStudioSessionMappingsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListStudioSessionMappingsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListSupportedInstanceTypes
///
/// A list of the instance types that Amazon EMR supports. You can filter the list by
/// Amazon Web Services Region and Amazon EMR release.
///
/// Container for the necessary parameters to execute the ListSupportedInstanceTypes service method.
///
/// The response from the ListSupportedInstanceTypes service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSupportedInstanceTypes Operation
public virtual ListSupportedInstanceTypesResponse ListSupportedInstanceTypes(ListSupportedInstanceTypesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSupportedInstanceTypesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSupportedInstanceTypesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// A list of the instance types that Amazon EMR supports. You can filter the list by
/// Amazon Web Services Region and Amazon EMR release.
///
/// Container for the necessary parameters to execute the ListSupportedInstanceTypes service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSupportedInstanceTypes service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ListSupportedInstanceTypes Operation
public virtual Task ListSupportedInstanceTypesAsync(ListSupportedInstanceTypesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSupportedInstanceTypesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSupportedInstanceTypesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ModifyCluster
///
/// Modifies the number of steps that can be executed concurrently for the cluster specified
/// using ClusterID.
///
/// Container for the necessary parameters to execute the ModifyCluster service method.
///
/// The response from the ModifyCluster service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ModifyCluster Operation
public virtual ModifyClusterResponse ModifyCluster(ModifyClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Modifies the number of steps that can be executed concurrently for the cluster specified
/// using ClusterID.
///
/// Container for the necessary parameters to execute the ModifyCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ModifyCluster service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ModifyCluster Operation
public virtual Task ModifyClusterAsync(ModifyClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ModifyInstanceFleet
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the ModifyInstanceFleet service method.
///
/// The response from the ModifyInstanceFleet service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ModifyInstanceFleet Operation
public virtual ModifyInstanceFleetResponse ModifyInstanceFleet(ModifyInstanceFleetRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyInstanceFleetRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyInstanceFleetResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
///
///
/// Container for the necessary parameters to execute the ModifyInstanceFleet service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ModifyInstanceFleet service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for ModifyInstanceFleet Operation
public virtual Task ModifyInstanceFleetAsync(ModifyInstanceFleetRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyInstanceFleetRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyInstanceFleetResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ModifyInstanceGroups
///
/// ModifyInstanceGroups modifies the number of nodes and configuration settings of an
/// instance group. The input parameters include the new target instance count for the
/// group and the instance group ID. The call will either succeed or fail atomically.
///
/// Container for the necessary parameters to execute the ModifyInstanceGroups service method.
///
/// The response from the ModifyInstanceGroups service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for ModifyInstanceGroups Operation
public virtual ModifyInstanceGroupsResponse ModifyInstanceGroups(ModifyInstanceGroupsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyInstanceGroupsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// ModifyInstanceGroups modifies the number of nodes and configuration settings of an
/// instance group. The input parameters include the new target instance count for the
/// group and the instance group ID. The call will either succeed or fail atomically.
///
/// Container for the necessary parameters to execute the ModifyInstanceGroups service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ModifyInstanceGroups service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for ModifyInstanceGroups Operation
public virtual Task ModifyInstanceGroupsAsync(ModifyInstanceGroupsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ModifyInstanceGroupsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ModifyInstanceGroupsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutAutoScalingPolicy
///
/// 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.
///
/// Container for the necessary parameters to execute the PutAutoScalingPolicy service method.
///
/// The response from the PutAutoScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutAutoScalingPolicy Operation
public virtual PutAutoScalingPolicyResponse PutAutoScalingPolicy(PutAutoScalingPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutAutoScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutAutoScalingPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the PutAutoScalingPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutAutoScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutAutoScalingPolicy Operation
public virtual Task PutAutoScalingPolicyAsync(PutAutoScalingPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutAutoScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutAutoScalingPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutAutoTerminationPolicy
///
///
///
/// 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.
///
///
/// Container for the necessary parameters to execute the PutAutoTerminationPolicy service method.
///
/// The response from the PutAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutAutoTerminationPolicy Operation
public virtual PutAutoTerminationPolicyResponse PutAutoTerminationPolicy(PutAutoTerminationPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutAutoTerminationPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
///
///
/// 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.
///
///
/// Container for the necessary parameters to execute the PutAutoTerminationPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutAutoTerminationPolicy Operation
public virtual Task PutAutoTerminationPolicyAsync(PutAutoTerminationPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutAutoTerminationPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutBlockPublicAccessConfiguration
///
/// Creates 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.
///
/// Container for the necessary parameters to execute the PutBlockPublicAccessConfiguration service method.
///
/// The response from the PutBlockPublicAccessConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for PutBlockPublicAccessConfiguration Operation
public virtual PutBlockPublicAccessConfigurationResponse PutBlockPublicAccessConfiguration(PutBlockPublicAccessConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutBlockPublicAccessConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutBlockPublicAccessConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates 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.
///
/// Container for the necessary parameters to execute the PutBlockPublicAccessConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutBlockPublicAccessConfiguration service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for PutBlockPublicAccessConfiguration Operation
public virtual Task PutBlockPublicAccessConfigurationAsync(PutBlockPublicAccessConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutBlockPublicAccessConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutBlockPublicAccessConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutManagedScalingPolicy
///
/// 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.
///
/// Container for the necessary parameters to execute the PutManagedScalingPolicy service method.
///
/// The response from the PutManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutManagedScalingPolicy Operation
public virtual PutManagedScalingPolicyResponse PutManagedScalingPolicy(PutManagedScalingPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutManagedScalingPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// 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.
///
/// Container for the necessary parameters to execute the PutManagedScalingPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for PutManagedScalingPolicy Operation
public virtual Task PutManagedScalingPolicyAsync(PutManagedScalingPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutManagedScalingPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RemoveAutoScalingPolicy
///
/// Removes an automatic scaling policy from a specified instance group within an Amazon
/// EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveAutoScalingPolicy service method.
///
/// The response from the RemoveAutoScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveAutoScalingPolicy Operation
public virtual RemoveAutoScalingPolicyResponse RemoveAutoScalingPolicy(RemoveAutoScalingPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveAutoScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveAutoScalingPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes an automatic scaling policy from a specified instance group within an Amazon
/// EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveAutoScalingPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RemoveAutoScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveAutoScalingPolicy Operation
public virtual Task RemoveAutoScalingPolicyAsync(RemoveAutoScalingPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveAutoScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveAutoScalingPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RemoveAutoTerminationPolicy
///
/// Removes an auto-termination policy from an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveAutoTerminationPolicy service method.
///
/// The response from the RemoveAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveAutoTerminationPolicy Operation
public virtual RemoveAutoTerminationPolicyResponse RemoveAutoTerminationPolicy(RemoveAutoTerminationPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveAutoTerminationPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes an auto-termination policy from an Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveAutoTerminationPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RemoveAutoTerminationPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveAutoTerminationPolicy Operation
public virtual Task RemoveAutoTerminationPolicyAsync(RemoveAutoTerminationPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveAutoTerminationPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveAutoTerminationPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RemoveManagedScalingPolicy
///
/// Removes a managed scaling policy from a specified Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveManagedScalingPolicy service method.
///
/// The response from the RemoveManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveManagedScalingPolicy Operation
public virtual RemoveManagedScalingPolicyResponse RemoveManagedScalingPolicy(RemoveManagedScalingPolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveManagedScalingPolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes a managed scaling policy from a specified Amazon EMR cluster.
///
/// Container for the necessary parameters to execute the RemoveManagedScalingPolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RemoveManagedScalingPolicy service method, as returned by ElasticMapReduce.
/// REST API Reference for RemoveManagedScalingPolicy Operation
public virtual Task RemoveManagedScalingPolicyAsync(RemoveManagedScalingPolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveManagedScalingPolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveManagedScalingPolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RemoveTags
///
/// Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.
/// Tags make it easier to associate resources in various ways, such as grouping clusters
/// to track your Amazon EMR resource allocation costs. For more information, see Tag
/// Clusters.
///
///
///
/// The following example removes the stack tag with value Prod from a cluster:
///
///
/// Container for the necessary parameters to execute the RemoveTags service method.
///
/// The response from the RemoveTags service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for RemoveTags Operation
public virtual RemoveTagsResponse RemoveTags(RemoveTagsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveTagsRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveTagsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes tags from an Amazon EMR resource, such as a cluster or Amazon EMR Studio.
/// Tags make it easier to associate resources in various ways, such as grouping clusters
/// to track your Amazon EMR resource allocation costs. For more information, see Tag
/// Clusters.
///
///
///
/// The following example removes the stack tag with value Prod from a cluster:
///
///
/// Container for the necessary parameters to execute the RemoveTags service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RemoveTags service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for RemoveTags Operation
public virtual Task RemoveTagsAsync(RemoveTagsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RemoveTagsRequestMarshaller.Instance;
options.ResponseUnmarshaller = RemoveTagsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region RunJobFlow
///
/// RunJobFlow creates and starts running a new cluster (job flow). The cluster runs the
/// steps specified. After the steps complete, the cluster stops and the HDFS partition
/// is lost. To prevent loss of data, configure the last step of the job flow to store
/// results in Amazon S3. If the JobFlowInstancesConfig KeepJobFlowAliveWhenNoSteps
/// parameter is set to TRUE
, the cluster transitions to the WAITING state
/// rather than shutting down after the steps have completed.
///
///
///
/// For additional protection, you can set the JobFlowInstancesConfig TerminationProtected
/// parameter to TRUE
to lock the cluster and prevent it from being terminated
/// by API call, user intervention, or in the event of a job flow error.
///
///
///
/// A maximum of 256 steps are allowed in each job flow.
///
///
///
/// If your cluster is long-running (such as a Hive data warehouse) or complex, you may
/// require more than 256 steps to process your data. You can bypass the 256-step limitation
/// in various ways, including using the SSH shell to connect to the master node and submitting
/// queries directly to the software running on the master node, such as Hive and Hadoop.
///
///
///
/// For long-running clusters, we recommend that you periodically store your results.
///
///
///
/// The instance fleets configuration is available only in Amazon EMR releases 4.8.0 and
/// later, excluding 5.0.x versions. The RunJobFlow request can contain InstanceFleets
/// parameters or InstanceGroups parameters, but not both.
///
///
///
/// Container for the necessary parameters to execute the RunJobFlow service method.
///
/// The response from the RunJobFlow service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for RunJobFlow Operation
public virtual RunJobFlowResponse RunJobFlow(RunJobFlowRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RunJobFlowRequestMarshaller.Instance;
options.ResponseUnmarshaller = RunJobFlowResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// RunJobFlow creates and starts running a new cluster (job flow). The cluster runs the
/// steps specified. After the steps complete, the cluster stops and the HDFS partition
/// is lost. To prevent loss of data, configure the last step of the job flow to store
/// results in Amazon S3. If the JobFlowInstancesConfig KeepJobFlowAliveWhenNoSteps
/// parameter is set to TRUE
, the cluster transitions to the WAITING state
/// rather than shutting down after the steps have completed.
///
///
///
/// For additional protection, you can set the JobFlowInstancesConfig TerminationProtected
/// parameter to TRUE
to lock the cluster and prevent it from being terminated
/// by API call, user intervention, or in the event of a job flow error.
///
///
///
/// A maximum of 256 steps are allowed in each job flow.
///
///
///
/// If your cluster is long-running (such as a Hive data warehouse) or complex, you may
/// require more than 256 steps to process your data. You can bypass the 256-step limitation
/// in various ways, including using the SSH shell to connect to the master node and submitting
/// queries directly to the software running on the master node, such as Hive and Hadoop.
///
///
///
/// For long-running clusters, we recommend that you periodically store your results.
///
///
///
/// The instance fleets configuration is available only in Amazon EMR releases 4.8.0 and
/// later, excluding 5.0.x versions. The RunJobFlow request can contain InstanceFleets
/// parameters or InstanceGroups parameters, but not both.
///
///
///
/// Container for the necessary parameters to execute the RunJobFlow service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RunJobFlow service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for RunJobFlow Operation
public virtual Task RunJobFlowAsync(RunJobFlowRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RunJobFlowRequestMarshaller.Instance;
options.ResponseUnmarshaller = RunJobFlowResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region SetTerminationProtection
///
/// SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in
/// the cluster cannot be terminated by user intervention, an API call, or in the event
/// of a job-flow error. The cluster still terminates upon successful completion of the
/// job flow. Calling SetTerminationProtection
on a cluster is similar to
/// calling the Amazon EC2 DisableAPITermination
API on all Amazon EC2 instances
/// in a cluster.
///
///
///
/// SetTerminationProtection
is used to prevent accidental termination of
/// a cluster and to ensure that in the event of an error, the instances persist so that
/// you can recover any data stored in their ephemeral instance storage.
///
///
///
/// To terminate a cluster that has been locked by setting SetTerminationProtection
/// to true
, you must first unlock the job flow by a subsequent call to SetTerminationProtection
/// in which you set the value to false
.
///
///
///
/// For more information, seeManaging
/// Cluster Termination in the Amazon EMR Management Guide.
///
///
/// Container for the necessary parameters to execute the SetTerminationProtection service method.
///
/// The response from the SetTerminationProtection service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for SetTerminationProtection Operation
public virtual SetTerminationProtectionResponse SetTerminationProtection(SetTerminationProtectionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = SetTerminationProtectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = SetTerminationProtectionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// SetTerminationProtection locks a cluster (job flow) so the Amazon EC2 instances in
/// the cluster cannot be terminated by user intervention, an API call, or in the event
/// of a job-flow error. The cluster still terminates upon successful completion of the
/// job flow. Calling SetTerminationProtection
on a cluster is similar to
/// calling the Amazon EC2 DisableAPITermination
API on all Amazon EC2 instances
/// in a cluster.
///
///
///
/// SetTerminationProtection
is used to prevent accidental termination of
/// a cluster and to ensure that in the event of an error, the instances persist so that
/// you can recover any data stored in their ephemeral instance storage.
///
///
///
/// To terminate a cluster that has been locked by setting SetTerminationProtection
/// to true
, you must first unlock the job flow by a subsequent call to SetTerminationProtection
/// in which you set the value to false
.
///
///
///
/// For more information, seeManaging
/// Cluster Termination in the Amazon EMR Management Guide.
///
///
/// Container for the necessary parameters to execute the SetTerminationProtection service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the SetTerminationProtection service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for SetTerminationProtection Operation
public virtual Task SetTerminationProtectionAsync(SetTerminationProtectionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = SetTerminationProtectionRequestMarshaller.Instance;
options.ResponseUnmarshaller = SetTerminationProtectionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region SetVisibleToAllUsers
///
///
///
/// The SetVisibleToAllUsers parameter is no longer supported. Your cluster may be visible
/// to all users in your account. To restrict cluster access using an IAM policy, see
/// Identity
/// and Access Management for Amazon EMR.
///
///
///
/// Sets the Cluster$VisibleToAllUsers value for an Amazon EMR cluster. When true
,
/// IAM principals in the Amazon Web Services account can perform Amazon EMR cluster actions
/// that their IAM policies allow. When false
, only the IAM principal that
/// created the cluster and the Amazon Web Services account root user can perform Amazon
/// EMR actions on the cluster, regardless of IAM permissions policies attached to other
/// IAM principals.
///
///
///
/// This action works on running clusters. When you create a cluster, use the RunJobFlowInput$VisibleToAllUsers
/// parameter.
///
///
///
/// For more information, see Understanding
/// the Amazon EMR Cluster VisibleToAllUsers Setting in the Amazon EMR Management
/// Guide.
///
///
/// Container for the necessary parameters to execute the SetVisibleToAllUsers service method.
///
/// The response from the SetVisibleToAllUsers service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for SetVisibleToAllUsers Operation
public virtual SetVisibleToAllUsersResponse SetVisibleToAllUsers(SetVisibleToAllUsersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = SetVisibleToAllUsersRequestMarshaller.Instance;
options.ResponseUnmarshaller = SetVisibleToAllUsersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
///
///
/// The SetVisibleToAllUsers parameter is no longer supported. Your cluster may be visible
/// to all users in your account. To restrict cluster access using an IAM policy, see
/// Identity
/// and Access Management for Amazon EMR.
///
///
///
/// Sets the Cluster$VisibleToAllUsers value for an Amazon EMR cluster. When true
,
/// IAM principals in the Amazon Web Services account can perform Amazon EMR cluster actions
/// that their IAM policies allow. When false
, only the IAM principal that
/// created the cluster and the Amazon Web Services account root user can perform Amazon
/// EMR actions on the cluster, regardless of IAM permissions policies attached to other
/// IAM principals.
///
///
///
/// This action works on running clusters. When you create a cluster, use the RunJobFlowInput$VisibleToAllUsers
/// parameter.
///
///
///
/// For more information, see Understanding
/// the Amazon EMR Cluster VisibleToAllUsers Setting in the Amazon EMR Management
/// Guide.
///
///
/// Container for the necessary parameters to execute the SetVisibleToAllUsers service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the SetVisibleToAllUsers service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for SetVisibleToAllUsers Operation
public virtual Task SetVisibleToAllUsersAsync(SetVisibleToAllUsersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = SetVisibleToAllUsersRequestMarshaller.Instance;
options.ResponseUnmarshaller = SetVisibleToAllUsersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartNotebookExecution
///
/// Starts a notebook execution.
///
/// Container for the necessary parameters to execute the StartNotebookExecution service method.
///
/// The response from the StartNotebookExecution service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for StartNotebookExecution Operation
public virtual StartNotebookExecutionResponse StartNotebookExecution(StartNotebookExecutionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartNotebookExecutionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Starts a notebook execution.
///
/// Container for the necessary parameters to execute the StartNotebookExecution service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartNotebookExecution service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for StartNotebookExecution Operation
public virtual Task StartNotebookExecutionAsync(StartNotebookExecutionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartNotebookExecutionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StopNotebookExecution
///
/// Stops a notebook execution.
///
/// Container for the necessary parameters to execute the StopNotebookExecution service method.
///
/// The response from the StopNotebookExecution service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for StopNotebookExecution Operation
public virtual StopNotebookExecutionResponse StopNotebookExecution(StopNotebookExecutionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopNotebookExecutionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Stops a notebook execution.
///
/// Container for the necessary parameters to execute the StopNotebookExecution service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StopNotebookExecution service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for StopNotebookExecution Operation
public virtual Task StopNotebookExecutionAsync(StopNotebookExecutionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StopNotebookExecutionRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopNotebookExecutionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TerminateJobFlows
///
/// TerminateJobFlows shuts a list of clusters (job flows) down. When a job flow is shut
/// down, any step not yet completed is canceled and the Amazon EC2 instances on which
/// the cluster is running are stopped. Any log files not already saved are uploaded to
/// Amazon S3 if a LogUri was specified when the cluster was created.
///
///
///
/// The maximum number of clusters allowed is 10. The call to TerminateJobFlows
/// is asynchronous. Depending on the configuration of the cluster, it may take up to
/// 1-5 minutes for the cluster to completely terminate and release allocated resources,
/// such as Amazon EC2 instances.
///
///
/// Container for the necessary parameters to execute the TerminateJobFlows service method.
///
/// The response from the TerminateJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for TerminateJobFlows Operation
public virtual TerminateJobFlowsResponse TerminateJobFlows(TerminateJobFlowsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TerminateJobFlowsRequestMarshaller.Instance;
options.ResponseUnmarshaller = TerminateJobFlowsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// TerminateJobFlows shuts a list of clusters (job flows) down. When a job flow is shut
/// down, any step not yet completed is canceled and the Amazon EC2 instances on which
/// the cluster is running are stopped. Any log files not already saved are uploaded to
/// Amazon S3 if a LogUri was specified when the cluster was created.
///
///
///
/// The maximum number of clusters allowed is 10. The call to TerminateJobFlows
/// is asynchronous. Depending on the configuration of the cluster, it may take up to
/// 1-5 minutes for the cluster to completely terminate and release allocated resources,
/// such as Amazon EC2 instances.
///
///
/// Container for the necessary parameters to execute the TerminateJobFlows service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the TerminateJobFlows service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
/// REST API Reference for TerminateJobFlows Operation
public virtual Task TerminateJobFlowsAsync(TerminateJobFlowsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = TerminateJobFlowsRequestMarshaller.Instance;
options.ResponseUnmarshaller = TerminateJobFlowsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateStudio
///
/// Updates an Amazon EMR Studio configuration, including attributes such as name, description,
/// and subnets.
///
/// Container for the necessary parameters to execute the UpdateStudio service method.
///
/// The response from the UpdateStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for UpdateStudio Operation
public virtual UpdateStudioResponse UpdateStudio(UpdateStudioRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStudioResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates an Amazon EMR Studio configuration, including attributes such as name, description,
/// and subnets.
///
/// Container for the necessary parameters to execute the UpdateStudio service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateStudio service method, as returned by ElasticMapReduce.
///
/// This exception occurs when there is an internal failure in the Amazon EMR service.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for UpdateStudio Operation
public virtual Task UpdateStudioAsync(UpdateStudioRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStudioRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStudioResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateStudioSessionMapping
///
/// Updates the session policy attached to the user or group for the specified Amazon
/// EMR Studio.
///
/// Container for the necessary parameters to execute the UpdateStudioSessionMapping service method.
///
/// The response from the UpdateStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for UpdateStudioSessionMapping Operation
public virtual UpdateStudioSessionMappingResponse UpdateStudioSessionMapping(UpdateStudioSessionMappingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStudioSessionMappingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the session policy attached to the user or group for the specified Amazon
/// EMR Studio.
///
/// Container for the necessary parameters to execute the UpdateStudioSessionMapping service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateStudioSessionMapping service method, as returned by ElasticMapReduce.
///
/// Indicates that an error occurred while processing the request and that the request
/// was not completed.
///
///
/// This exception occurs when there is something wrong with user input.
///
/// REST API Reference for UpdateStudioSessionMapping Operation
public virtual Task UpdateStudioSessionMappingAsync(UpdateStudioSessionMappingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateStudioSessionMappingRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateStudioSessionMappingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}