/*
* 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 emr-containers-2020-10-01.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.EMRContainers.Model;
using Amazon.EMRContainers.Model.Internal.MarshallTransformations;
using Amazon.EMRContainers.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.EMRContainers
{
///
/// Implementation for accessing EMRContainers
///
/// Amazon EMR on EKS provides a deployment option for Amazon EMR that allows you to run
/// open-source big data frameworks on Amazon Elastic Kubernetes Service (Amazon EKS).
/// With this deployment option, you can focus on running analytics workloads while Amazon
/// EMR on EKS builds, configures, and manages containers for open-source applications.
/// For more information about Amazon EMR on EKS concepts and tasks, see What
/// is shared id="EMR-EKS"/>.
///
///
///
/// Amazon EMR containers is the API name for Amazon EMR on EKS. The emr-containers
/// prefix is used in the following scenarios:
///
/// -
///
/// It is the prefix in the CLI commands for Amazon EMR on EKS. For example,
aws
/// emr-containers start-job-run.
///
/// -
///
/// It is the prefix before IAM policy actions for Amazon EMR on EKS. For example,
"Action":
/// [ "emr-containers:StartJobRun"]. For more information, see Policy
/// actions for Amazon EMR on EKS.
///
/// -
///
/// It is the prefix used in Amazon EMR on EKS service endpoints. For example,
emr-containers.us-east-2.amazonaws.com.
/// For more information, see Amazon
/// EMR on EKSService Endpoints.
///
///
///
public partial class AmazonEMRContainersClient : AmazonServiceClient, IAmazonEMRContainers
{
private static IServiceMetadata serviceMetadata = new AmazonEMRContainersMetadata();
private IEMRContainersPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IEMRContainersPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new EMRContainersPaginatorFactory(this);
}
return this._paginators;
}
}
#region Constructors
///
/// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonEMRContainersConfig()) { }
///
/// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonEMRContainersConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient Configuration Object
public AmazonEMRContainersClient(AmazonEMRContainersConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonEMRContainersClient with AWS Credentials
///
/// AWS Credentials
public AmazonEMRContainersClient(AWSCredentials credentials)
: this(credentials, new AmazonEMRContainersConfig())
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonEMRContainersClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonEMRContainersConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Credentials and an
/// AmazonEMRContainersClient Configuration object.
///
/// AWS Credentials
/// The AmazonEMRContainersClient Configuration Object
public AmazonEMRContainersClient(AWSCredentials credentials, AmazonEMRContainersConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonEMRContainersConfig())
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonEMRContainersConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonEMRContainersClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonEMRContainersClient Configuration Object
public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonEMRContainersConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonEMRContainersConfig())
{
}
///
/// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonEMRContainersConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonEMRContainersClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonEMRContainersClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonEMRContainersClient Configuration Object
public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonEMRContainersConfig 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 AmazonEMRContainersEndpointResolver());
}
///
/// 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 CancelJobRun
///
/// Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script,
/// or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the CancelJobRun service method.
///
/// The response from the CancelJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CancelJobRun Operation
public virtual CancelJobRunResponse CancelJobRun(CancelJobRunRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelJobRunResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script,
/// or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the CancelJobRun service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CancelJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CancelJobRun Operation
public virtual Task CancelJobRunAsync(CancelJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CancelJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = CancelJobRunResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateJobTemplate
///
/// Creates a job template. Job template stores values of StartJobRun API request in a
/// template and can be used to start a job run. Job template allows two use cases: avoid
/// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun
/// API request.
///
/// Container for the necessary parameters to execute the CreateJobTemplate service method.
///
/// The response from the CreateJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateJobTemplate Operation
public virtual CreateJobTemplateResponse CreateJobTemplate(CreateJobTemplateRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateJobTemplateResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a job template. Job template stores values of StartJobRun API request in a
/// template and can be used to start a job run. Job template allows two use cases: avoid
/// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun
/// API request.
///
/// Container for the necessary parameters to execute the CreateJobTemplate service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateJobTemplate Operation
public virtual Task CreateJobTemplateAsync(CreateJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateJobTemplateResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateManagedEndpoint
///
/// Creates a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR
/// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual
/// cluster.
///
/// Container for the necessary parameters to execute the CreateManagedEndpoint service method.
///
/// The response from the CreateManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateManagedEndpoint Operation
public virtual CreateManagedEndpointResponse CreateManagedEndpoint(CreateManagedEndpointRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateManagedEndpointResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR
/// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual
/// cluster.
///
/// Container for the necessary parameters to execute the CreateManagedEndpoint service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateManagedEndpoint Operation
public virtual Task CreateManagedEndpointAsync(CreateManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateManagedEndpointResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateVirtualCluster
///
/// Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS.
/// You can create, describe, list and delete virtual clusters. They do not consume any
/// additional resource in your system. A single virtual cluster maps to a single Kubernetes
/// namespace. Given this relationship, you can model virtual clusters the same way you
/// model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the CreateVirtualCluster service method.
///
/// The response from the CreateVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateVirtualCluster Operation
public virtual CreateVirtualClusterResponse CreateVirtualCluster(CreateVirtualClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateVirtualClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS.
/// You can create, describe, list and delete virtual clusters. They do not consume any
/// additional resource in your system. A single virtual cluster maps to a single Kubernetes
/// namespace. Given this relationship, you can model virtual clusters the same way you
/// model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the CreateVirtualCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for CreateVirtualCluster Operation
public virtual Task CreateVirtualClusterAsync(CreateVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateVirtualClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteJobTemplate
///
/// Deletes a job template. Job template stores values of StartJobRun API request in a
/// template and can be used to start a job run. Job template allows two use cases: avoid
/// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun
/// API request.
///
/// Container for the necessary parameters to execute the DeleteJobTemplate service method.
///
/// The response from the DeleteJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteJobTemplate Operation
public virtual DeleteJobTemplateResponse DeleteJobTemplate(DeleteJobTemplateRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteJobTemplateResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a job template. Job template stores values of StartJobRun API request in a
/// template and can be used to start a job run. Job template allows two use cases: avoid
/// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun
/// API request.
///
/// Container for the necessary parameters to execute the DeleteJobTemplate service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteJobTemplate Operation
public virtual Task DeleteJobTemplateAsync(DeleteJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteJobTemplateResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteManagedEndpoint
///
/// Deletes a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR
/// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual
/// cluster.
///
/// Container for the necessary parameters to execute the DeleteManagedEndpoint service method.
///
/// The response from the DeleteManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteManagedEndpoint Operation
public virtual DeleteManagedEndpointResponse DeleteManagedEndpoint(DeleteManagedEndpointRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteManagedEndpointResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR
/// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual
/// cluster.
///
/// Container for the necessary parameters to execute the DeleteManagedEndpoint service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteManagedEndpoint Operation
public virtual Task DeleteManagedEndpointAsync(DeleteManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteManagedEndpointResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteVirtualCluster
///
/// Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS.
/// You can create, describe, list and delete virtual clusters. They do not consume any
/// additional resource in your system. A single virtual cluster maps to a single Kubernetes
/// namespace. Given this relationship, you can model virtual clusters the same way you
/// model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the DeleteVirtualCluster service method.
///
/// The response from the DeleteVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteVirtualCluster Operation
public virtual DeleteVirtualClusterResponse DeleteVirtualCluster(DeleteVirtualClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteVirtualClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS.
/// You can create, describe, list and delete virtual clusters. They do not consume any
/// additional resource in your system. A single virtual cluster maps to a single Kubernetes
/// namespace. Given this relationship, you can model virtual clusters the same way you
/// model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the DeleteVirtualCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DeleteVirtualCluster Operation
public virtual Task DeleteVirtualClusterAsync(DeleteVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteVirtualClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeJobRun
///
/// Displays detailed information about a job run. A job run is a unit of work, such as
/// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the DescribeJobRun service method.
///
/// The response from the DescribeJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeJobRun Operation
public virtual DescribeJobRunResponse DescribeJobRun(DescribeJobRunRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobRunResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Displays detailed information about a job run. A job run is a unit of work, such as
/// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the DescribeJobRun service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeJobRun Operation
public virtual Task DescribeJobRunAsync(DescribeJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobRunResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeJobTemplate
///
/// Displays detailed information about a specified job template. Job template stores
/// values of StartJobRun API request in a template and can be used to start a job run.
/// Job template allows two use cases: avoid repeating recurring StartJobRun API request
/// values, enforcing certain values in StartJobRun API request.
///
/// Container for the necessary parameters to execute the DescribeJobTemplate service method.
///
/// The response from the DescribeJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeJobTemplate Operation
public virtual DescribeJobTemplateResponse DescribeJobTemplate(DescribeJobTemplateRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobTemplateResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Displays detailed information about a specified job template. Job template stores
/// values of StartJobRun API request in a template and can be used to start a job run.
/// Job template allows two use cases: avoid repeating recurring StartJobRun API request
/// values, enforcing certain values in StartJobRun API request.
///
/// Container for the necessary parameters to execute the DescribeJobTemplate service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeJobTemplate service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeJobTemplate Operation
public virtual Task DescribeJobTemplateAsync(DescribeJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeJobTemplateRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeJobTemplateResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeManagedEndpoint
///
/// Displays detailed information about a managed endpoint. A managed endpoint is a gateway
/// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can
/// communicate with your virtual cluster.
///
/// Container for the necessary parameters to execute the DescribeManagedEndpoint service method.
///
/// The response from the DescribeManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeManagedEndpoint Operation
public virtual DescribeManagedEndpointResponse DescribeManagedEndpoint(DescribeManagedEndpointRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeManagedEndpointResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Displays detailed information about a managed endpoint. A managed endpoint is a gateway
/// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can
/// communicate with your virtual cluster.
///
/// Container for the necessary parameters to execute the DescribeManagedEndpoint service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeManagedEndpoint service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeManagedEndpoint Operation
public virtual Task DescribeManagedEndpointAsync(DescribeManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeManagedEndpointRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeManagedEndpointResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeVirtualCluster
///
/// Displays detailed information about a specified virtual cluster. Virtual cluster is
/// a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual
/// clusters. They do not consume any additional resource in your system. A single virtual
/// cluster maps to a single Kubernetes namespace. Given this relationship, you can model
/// virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the DescribeVirtualCluster service method.
///
/// The response from the DescribeVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeVirtualCluster Operation
public virtual DescribeVirtualClusterResponse DescribeVirtualCluster(DescribeVirtualClusterRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeVirtualClusterResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Displays detailed information about a specified virtual cluster. Virtual cluster is
/// a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual
/// clusters. They do not consume any additional resource in your system. A single virtual
/// cluster maps to a single Kubernetes namespace. Given this relationship, you can model
/// virtual clusters the same way you model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the DescribeVirtualCluster service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeVirtualCluster service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for DescribeVirtualCluster Operation
public virtual Task DescribeVirtualClusterAsync(DescribeVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeVirtualClusterRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeVirtualClusterResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetManagedEndpointSessionCredentials
///
/// Generate a session token to connect to a managed endpoint.
///
/// Container for the necessary parameters to execute the GetManagedEndpointSessionCredentials service method.
///
/// The response from the GetManagedEndpointSessionCredentials service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The request throttled.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for GetManagedEndpointSessionCredentials Operation
public virtual GetManagedEndpointSessionCredentialsResponse GetManagedEndpointSessionCredentials(GetManagedEndpointSessionCredentialsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetManagedEndpointSessionCredentialsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetManagedEndpointSessionCredentialsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Generate a session token to connect to a managed endpoint.
///
/// Container for the necessary parameters to execute the GetManagedEndpointSessionCredentials service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetManagedEndpointSessionCredentials service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The request throttled.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for GetManagedEndpointSessionCredentials Operation
public virtual Task GetManagedEndpointSessionCredentialsAsync(GetManagedEndpointSessionCredentialsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetManagedEndpointSessionCredentialsRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetManagedEndpointSessionCredentialsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListJobRuns
///
/// Lists job runs based on a set of parameters. A job run is a unit of work, such as
/// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the ListJobRuns service method.
///
/// The response from the ListJobRuns service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListJobRuns Operation
public virtual ListJobRunsResponse ListJobRuns(ListJobRunsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListJobRunsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListJobRunsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists job runs based on a set of parameters. A job run is a unit of work, such as
/// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the ListJobRuns service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListJobRuns service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListJobRuns Operation
public virtual Task ListJobRunsAsync(ListJobRunsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListJobRunsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListJobRunsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListJobTemplates
///
/// Lists job templates based on a set of parameters. Job template stores values of StartJobRun
/// API request in a template and can be used to start a job run. Job template allows
/// two use cases: avoid repeating recurring StartJobRun API request values, enforcing
/// certain values in StartJobRun API request.
///
/// Container for the necessary parameters to execute the ListJobTemplates service method.
///
/// The response from the ListJobTemplates service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListJobTemplates Operation
public virtual ListJobTemplatesResponse ListJobTemplates(ListJobTemplatesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListJobTemplatesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListJobTemplatesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists job templates based on a set of parameters. Job template stores values of StartJobRun
/// API request in a template and can be used to start a job run. Job template allows
/// two use cases: avoid repeating recurring StartJobRun API request values, enforcing
/// certain values in StartJobRun API request.
///
/// Container for the necessary parameters to execute the ListJobTemplates service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListJobTemplates service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListJobTemplates Operation
public virtual Task ListJobTemplatesAsync(ListJobTemplatesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListJobTemplatesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListJobTemplatesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListManagedEndpoints
///
/// Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway
/// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can
/// communicate with your virtual cluster.
///
/// Container for the necessary parameters to execute the ListManagedEndpoints service method.
///
/// The response from the ListManagedEndpoints service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListManagedEndpoints Operation
public virtual ListManagedEndpointsResponse ListManagedEndpoints(ListManagedEndpointsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListManagedEndpointsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListManagedEndpointsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway
/// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can
/// communicate with your virtual cluster.
///
/// Container for the necessary parameters to execute the ListManagedEndpoints service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListManagedEndpoints service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListManagedEndpoints Operation
public virtual Task ListManagedEndpointsAsync(ListManagedEndpointsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListManagedEndpointsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListManagedEndpointsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListTagsForResource
///
/// Lists the tags assigned to the resources.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListTagsForResource Operation
public virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists the tags assigned to the resources.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListTagsForResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListTagsForResource Operation
public virtual Task ListTagsForResourceAsync(ListTagsForResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListVirtualClusters
///
/// Lists information about the specified virtual cluster. Virtual cluster is a managed
/// entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters.
/// They do not consume any additional resource in your system. A single virtual cluster
/// maps to a single Kubernetes namespace. Given this relationship, you can model virtual
/// clusters the same way you model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the ListVirtualClusters service method.
///
/// The response from the ListVirtualClusters service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListVirtualClusters Operation
public virtual ListVirtualClustersResponse ListVirtualClusters(ListVirtualClustersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListVirtualClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListVirtualClustersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists information about the specified virtual cluster. Virtual cluster is a managed
/// entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters.
/// They do not consume any additional resource in your system. A single virtual cluster
/// maps to a single Kubernetes namespace. Given this relationship, you can model virtual
/// clusters the same way you model Kubernetes namespaces to meet your requirements.
///
/// Container for the necessary parameters to execute the ListVirtualClusters service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListVirtualClusters service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for ListVirtualClusters Operation
public virtual Task ListVirtualClustersAsync(ListVirtualClustersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListVirtualClustersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListVirtualClustersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartJobRun
///
/// Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script,
/// or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the StartJobRun service method.
///
/// The response from the StartJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for StartJobRun Operation
public virtual StartJobRunResponse StartJobRun(StartJobRunRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartJobRunResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script,
/// or SparkSQL query, that you submit to Amazon EMR on EKS.
///
/// Container for the necessary parameters to execute the StartJobRun service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartJobRun service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for StartJobRun Operation
public virtual Task StartJobRunAsync(StartJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartJobRunRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartJobRunResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TagResource
///
/// Assigns tags to resources. A tag is a label that you assign to an Amazon Web Services
/// resource. Each tag consists of a key and an optional value, both of which you define.
/// Tags enable you to categorize your Amazon Web Services resources by attributes such
/// as purpose, owner, or environment. When you have many resources of the same type,
/// you can quickly identify a specific resource based on the tags you've assigned to
/// it. For example, you can define a set of tags for your Amazon EMR on EKS clusters
/// to help you track each cluster's owner and stack level. We recommend that you devise
/// a consistent set of tag keys for each resource type. You can then search and filter
/// the resources based on the tags that you add.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for TagResource Operation
public virtual TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Assigns tags to resources. A tag is a label that you assign to an Amazon Web Services
/// resource. Each tag consists of a key and an optional value, both of which you define.
/// Tags enable you to categorize your Amazon Web Services resources by attributes such
/// as purpose, owner, or environment. When you have many resources of the same type,
/// you can quickly identify a specific resource based on the tags you've assigned to
/// it. For example, you can define a set of tags for your Amazon EMR on EKS clusters
/// to help you track each cluster's owner and stack level. We recommend that you devise
/// a consistent set of tag keys for each resource type. You can then search and filter
/// the resources based on the tags that you add.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the TagResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for TagResource Operation
public virtual Task TagResourceAsync(TagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UntagResource
///
/// Removes tags from resources.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for UntagResource Operation
public virtual UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes tags from resources.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UntagResource service method, as returned by EMRContainers.
///
/// This is an internal server exception.
///
///
/// The specified resource was not found.
///
///
/// There are invalid parameters in the client request.
///
/// REST API Reference for UntagResource Operation
public virtual Task UntagResourceAsync(UntagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}