/*
* 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 kinesisanalyticsv2-2018-05-23.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.KinesisAnalyticsV2.Model;
using Amazon.KinesisAnalyticsV2.Model.Internal.MarshallTransformations;
using Amazon.KinesisAnalyticsV2.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.KinesisAnalyticsV2
{
///
/// Implementation for accessing KinesisAnalyticsV2
///
/// Amazon Kinesis Data Analytics is a fully managed service that you can use to process
/// and analyze streaming data using Java, SQL, or Scala. The service enables you to quickly
/// author and run Java, SQL, or Scala code against streaming sources to perform time
/// series analytics, feed real-time dashboards, and create real-time metrics.
///
public partial class AmazonKinesisAnalyticsV2Client : AmazonServiceClient, IAmazonKinesisAnalyticsV2
{
private static IServiceMetadata serviceMetadata = new AmazonKinesisAnalyticsV2Metadata();
#region Constructors
///
/// Constructs AmazonKinesisAnalyticsV2Client 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 AmazonKinesisAnalyticsV2Client()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonKinesisAnalyticsV2Config()) { }
///
/// Constructs AmazonKinesisAnalyticsV2Client 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 AmazonKinesisAnalyticsV2Client(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonKinesisAnalyticsV2Config{RegionEndpoint = region}) { }
///
/// Constructs AmazonKinesisAnalyticsV2Client 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 AmazonKinesisAnalyticsV2Client Configuration Object
public AmazonKinesisAnalyticsV2Client(AmazonKinesisAnalyticsV2Config config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Credentials
///
/// AWS Credentials
public AmazonKinesisAnalyticsV2Client(AWSCredentials credentials)
: this(credentials, new AmazonKinesisAnalyticsV2Config())
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonKinesisAnalyticsV2Client(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonKinesisAnalyticsV2Config{RegionEndpoint = region})
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Credentials and an
/// AmazonKinesisAnalyticsV2Client Configuration object.
///
/// AWS Credentials
/// The AmazonKinesisAnalyticsV2Client Configuration Object
public AmazonKinesisAnalyticsV2Client(AWSCredentials credentials, AmazonKinesisAnalyticsV2Config clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonKinesisAnalyticsV2Config())
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonKinesisAnalyticsV2Config() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Access Key ID, AWS Secret Key and an
/// AmazonKinesisAnalyticsV2Client Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonKinesisAnalyticsV2Client Configuration Object
public AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey, AmazonKinesisAnalyticsV2Config clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKinesisAnalyticsV2Config())
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client 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 AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKinesisAnalyticsV2Config{RegionEndpoint = region})
{
}
///
/// Constructs AmazonKinesisAnalyticsV2Client with AWS Access Key ID, AWS Secret Key and an
/// AmazonKinesisAnalyticsV2Client Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonKinesisAnalyticsV2Client Configuration Object
public AmazonKinesisAnalyticsV2Client(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonKinesisAnalyticsV2Config 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 AmazonKinesisAnalyticsV2EndpointResolver());
}
///
/// 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 AddApplicationCloudWatchLoggingOption
///
/// Adds an Amazon CloudWatch log stream to monitor application configuration errors.
///
/// Container for the necessary parameters to execute the AddApplicationCloudWatchLoggingOption service method.
///
/// The response from the AddApplicationCloudWatchLoggingOption service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationCloudWatchLoggingOption Operation
public virtual AddApplicationCloudWatchLoggingOptionResponse AddApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds an Amazon CloudWatch log stream to monitor application configuration errors.
///
/// Container for the necessary parameters to execute the AddApplicationCloudWatchLoggingOption service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationCloudWatchLoggingOption service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationCloudWatchLoggingOption Operation
public virtual Task AddApplicationCloudWatchLoggingOptionAsync(AddApplicationCloudWatchLoggingOptionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddApplicationInput
///
/// Adds a streaming source to your SQL-based Kinesis Data Analytics application.
///
///
///
/// You can add a streaming source when you create an application, or you can use this
/// operation to add a streaming source after you create an application. For more information,
/// see CreateApplication.
///
///
///
/// Any configuration update, including adding a streaming source using this operation,
/// results in a new version of the application. You can use the DescribeApplication
/// operation to find the current application version.
///
///
/// Container for the necessary parameters to execute the AddApplicationInput service method.
///
/// The response from the AddApplicationInput service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationInput Operation
public virtual AddApplicationInputResponse AddApplicationInput(AddApplicationInputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds a streaming source to your SQL-based Kinesis Data Analytics application.
///
///
///
/// You can add a streaming source when you create an application, or you can use this
/// operation to add a streaming source after you create an application. For more information,
/// see CreateApplication.
///
///
///
/// Any configuration update, including adding a streaming source using this operation,
/// results in a new version of the application. You can use the DescribeApplication
/// operation to find the current application version.
///
///
/// Container for the necessary parameters to execute the AddApplicationInput service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationInput service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationInput Operation
public virtual Task AddApplicationInputAsync(AddApplicationInputRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddApplicationInputProcessingConfiguration
///
/// Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics
/// application. An input processor pre-processes records on the input stream before the
/// application's SQL code executes. Currently, the only input processor available is
/// Amazon Lambda.
///
/// Container for the necessary parameters to execute the AddApplicationInputProcessingConfiguration service method.
///
/// The response from the AddApplicationInputProcessingConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationInputProcessingConfiguration Operation
public virtual AddApplicationInputProcessingConfigurationResponse AddApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics
/// application. An input processor pre-processes records on the input stream before the
/// application's SQL code executes. Currently, the only input processor available is
/// Amazon Lambda.
///
/// Container for the necessary parameters to execute the AddApplicationInputProcessingConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationInputProcessingConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationInputProcessingConfiguration Operation
public virtual Task AddApplicationInputProcessingConfigurationAsync(AddApplicationInputProcessingConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddApplicationOutput
///
/// Adds an external destination to your SQL-based Kinesis Data Analytics application.
///
///
///
/// If you want Kinesis Data Analytics to deliver data from an in-application stream within
/// your application to an external destination (such as an Kinesis data stream, a Kinesis
/// Data Firehose delivery stream, or an Amazon Lambda function), you add the relevant
/// configuration to your application using this operation. You can configure one or more
/// outputs for your application. Each output configuration maps an in-application stream
/// and an external destination.
///
///
///
/// You can use one of the output configurations to deliver data from your in-application
/// error stream to an external destination so that you can analyze the errors.
///
///
///
/// Any configuration update, including adding a streaming source using this operation,
/// results in a new version of the application. You can use the DescribeApplication
/// operation to find the current application version.
///
///
/// Container for the necessary parameters to execute the AddApplicationOutput service method.
///
/// The response from the AddApplicationOutput service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationOutput Operation
public virtual AddApplicationOutputResponse AddApplicationOutput(AddApplicationOutputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationOutputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds an external destination to your SQL-based Kinesis Data Analytics application.
///
///
///
/// If you want Kinesis Data Analytics to deliver data from an in-application stream within
/// your application to an external destination (such as an Kinesis data stream, a Kinesis
/// Data Firehose delivery stream, or an Amazon Lambda function), you add the relevant
/// configuration to your application using this operation. You can configure one or more
/// outputs for your application. Each output configuration maps an in-application stream
/// and an external destination.
///
///
///
/// You can use one of the output configurations to deliver data from your in-application
/// error stream to an external destination so that you can analyze the errors.
///
///
///
/// Any configuration update, including adding a streaming source using this operation,
/// results in a new version of the application. You can use the DescribeApplication
/// operation to find the current application version.
///
///
/// Container for the necessary parameters to execute the AddApplicationOutput service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationOutput service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationOutput Operation
public virtual Task AddApplicationOutputAsync(AddApplicationOutputRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationOutputResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddApplicationReferenceDataSource
///
/// Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.
///
///
///
/// Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates
/// an in-application table within your application. In the request, you provide the source
/// (S3 bucket name and object key name), name of the in-application table to create,
/// and the necessary mapping information that describes how data in an Amazon S3 object
/// maps to columns in the resulting in-application table.
///
///
/// Container for the necessary parameters to execute the AddApplicationReferenceDataSource service method.
///
/// The response from the AddApplicationReferenceDataSource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationReferenceDataSource Operation
public virtual AddApplicationReferenceDataSourceResponse AddApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds a reference data source to an existing SQL-based Kinesis Data Analytics application.
///
///
///
/// Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates
/// an in-application table within your application. In the request, you provide the source
/// (S3 bucket name and object key name), name of the in-application table to create,
/// and the necessary mapping information that describes how data in an Amazon S3 object
/// maps to columns in the resulting in-application table.
///
///
/// Container for the necessary parameters to execute the AddApplicationReferenceDataSource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationReferenceDataSource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationReferenceDataSource Operation
public virtual Task AddApplicationReferenceDataSourceAsync(AddApplicationReferenceDataSourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region AddApplicationVpcConfiguration
///
/// Adds a Virtual Private Cloud (VPC) configuration to the application. Applications
/// can use VPCs to store and access resources securely.
///
///
///
/// Note the following about VPC configurations for Kinesis Data Analytics applications:
///
/// -
///
/// VPC configurations are not supported for SQL applications.
///
///
-
///
/// When a VPC is added to a Kinesis Data Analytics application, the application can no
/// longer be accessed from the Internet directly. To enable Internet access to the application,
/// add an Internet gateway to your VPC.
///
///
///
/// Container for the necessary parameters to execute the AddApplicationVpcConfiguration service method.
///
/// The response from the AddApplicationVpcConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationVpcConfiguration Operation
public virtual AddApplicationVpcConfigurationResponse AddApplicationVpcConfiguration(AddApplicationVpcConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationVpcConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationVpcConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Adds a Virtual Private Cloud (VPC) configuration to the application. Applications
/// can use VPCs to store and access resources securely.
///
///
///
/// Note the following about VPC configurations for Kinesis Data Analytics applications:
///
/// -
///
/// VPC configurations are not supported for SQL applications.
///
///
-
///
/// When a VPC is added to a Kinesis Data Analytics application, the application can no
/// longer be accessed from the Internet directly. To enable Internet access to the application,
/// add an Internet gateway to your VPC.
///
///
///
/// Container for the necessary parameters to execute the AddApplicationVpcConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the AddApplicationVpcConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for AddApplicationVpcConfiguration Operation
public virtual Task AddApplicationVpcConfigurationAsync(AddApplicationVpcConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationVpcConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationVpcConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateApplication
///
/// Creates a Kinesis Data Analytics application. For information about creating a Kinesis
/// Data Analytics application, see Creating
/// an Application.
///
/// Container for the necessary parameters to execute the CreateApplication service method.
///
/// The response from the CreateApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for CreateApplication Operation
public virtual CreateApplicationResponse CreateApplication(CreateApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a Kinesis Data Analytics application. For information about creating a Kinesis
/// Data Analytics application, see Creating
/// an Application.
///
/// Container for the necessary parameters to execute the CreateApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for CreateApplication Operation
public virtual Task CreateApplicationAsync(CreateApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateApplicationPresignedUrl
///
/// Creates and returns a URL that you can use to connect to an application's extension.
///
///
///
/// The IAM role or user used to call this API defines the permissions to access the extension.
/// After the presigned URL is created, no additional permission is required to access
/// this URL. IAM authorization policies for this API are also enforced for every HTTP
/// request that attempts to connect to the extension.
///
///
///
/// You control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds
/// parameter. If you do not provide this parameter, the returned URL is valid for twelve
/// hours.
///
///
///
/// The URL that you get from a call to CreateApplicationPresignedUrl must be used within
/// 3 minutes to be valid. If you first try to use the URL after the 3-minute limit expires,
/// the service returns an HTTP 403 Forbidden error.
///
///
///
/// Container for the necessary parameters to execute the CreateApplicationPresignedUrl service method.
///
/// The response from the CreateApplicationPresignedUrl service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for CreateApplicationPresignedUrl Operation
public virtual CreateApplicationPresignedUrlResponse CreateApplicationPresignedUrl(CreateApplicationPresignedUrlRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationPresignedUrlRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationPresignedUrlResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates and returns a URL that you can use to connect to an application's extension.
///
///
///
/// The IAM role or user used to call this API defines the permissions to access the extension.
/// After the presigned URL is created, no additional permission is required to access
/// this URL. IAM authorization policies for this API are also enforced for every HTTP
/// request that attempts to connect to the extension.
///
///
///
/// You control the amount of time that the URL will be valid using the SessionExpirationDurationInSeconds
/// parameter. If you do not provide this parameter, the returned URL is valid for twelve
/// hours.
///
///
///
/// The URL that you get from a call to CreateApplicationPresignedUrl must be used within
/// 3 minutes to be valid. If you first try to use the URL after the 3-minute limit expires,
/// the service returns an HTTP 403 Forbidden error.
///
///
///
/// Container for the necessary parameters to execute the CreateApplicationPresignedUrl service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateApplicationPresignedUrl service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for CreateApplicationPresignedUrl Operation
public virtual Task CreateApplicationPresignedUrlAsync(CreateApplicationPresignedUrlRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationPresignedUrlRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationPresignedUrlResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateApplicationSnapshot
///
/// Creates a snapshot of the application's state data.
///
/// Container for the necessary parameters to execute the CreateApplicationSnapshot service method.
///
/// The response from the CreateApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for CreateApplicationSnapshot Operation
public virtual CreateApplicationSnapshotResponse CreateApplicationSnapshot(CreateApplicationSnapshotRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationSnapshotResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a snapshot of the application's state data.
///
/// Container for the necessary parameters to execute the CreateApplicationSnapshot service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for CreateApplicationSnapshot Operation
public virtual Task CreateApplicationSnapshotAsync(CreateApplicationSnapshotRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationSnapshotResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplication
///
/// Deletes the specified application. Kinesis Data Analytics halts application execution
/// and deletes the application.
///
/// Container for the necessary parameters to execute the DeleteApplication service method.
///
/// The response from the DeleteApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplication Operation
public virtual DeleteApplicationResponse DeleteApplication(DeleteApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes the specified application. Kinesis Data Analytics halts application execution
/// and deletes the application.
///
/// Container for the necessary parameters to execute the DeleteApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplication Operation
public virtual Task DeleteApplicationAsync(DeleteApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationCloudWatchLoggingOption
///
/// Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application.
///
/// Container for the necessary parameters to execute the DeleteApplicationCloudWatchLoggingOption service method.
///
/// The response from the DeleteApplicationCloudWatchLoggingOption service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationCloudWatchLoggingOption Operation
public virtual DeleteApplicationCloudWatchLoggingOptionResponse DeleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application.
///
/// Container for the necessary parameters to execute the DeleteApplicationCloudWatchLoggingOption service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationCloudWatchLoggingOption service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationCloudWatchLoggingOption Operation
public virtual Task DeleteApplicationCloudWatchLoggingOptionAsync(DeleteApplicationCloudWatchLoggingOptionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationInputProcessingConfiguration
///
/// Deletes an InputProcessingConfiguration from an input.
///
/// Container for the necessary parameters to execute the DeleteApplicationInputProcessingConfiguration service method.
///
/// The response from the DeleteApplicationInputProcessingConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationInputProcessingConfiguration Operation
public virtual DeleteApplicationInputProcessingConfigurationResponse DeleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes an InputProcessingConfiguration from an input.
///
/// Container for the necessary parameters to execute the DeleteApplicationInputProcessingConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationInputProcessingConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationInputProcessingConfiguration Operation
public virtual Task DeleteApplicationInputProcessingConfigurationAsync(DeleteApplicationInputProcessingConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationOutput
///
/// Deletes the output destination configuration from your SQL-based Kinesis Data Analytics
/// application's configuration. Kinesis Data Analytics will no longer write data from
/// the corresponding in-application stream to the external output destination.
///
/// Container for the necessary parameters to execute the DeleteApplicationOutput service method.
///
/// The response from the DeleteApplicationOutput service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationOutput Operation
public virtual DeleteApplicationOutputResponse DeleteApplicationOutput(DeleteApplicationOutputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationOutputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes the output destination configuration from your SQL-based Kinesis Data Analytics
/// application's configuration. Kinesis Data Analytics will no longer write data from
/// the corresponding in-application stream to the external output destination.
///
/// Container for the necessary parameters to execute the DeleteApplicationOutput service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationOutput service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationOutput Operation
public virtual Task DeleteApplicationOutputAsync(DeleteApplicationOutputRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationOutputResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationReferenceDataSource
///
/// Deletes a reference data source configuration from the specified SQL-based Kinesis
/// Data Analytics application's configuration.
///
///
///
/// If the application is running, Kinesis Data Analytics immediately removes the in-application
/// table that you created using the AddApplicationReferenceDataSource operation.
///
///
///
/// Container for the necessary parameters to execute the DeleteApplicationReferenceDataSource service method.
///
/// The response from the DeleteApplicationReferenceDataSource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationReferenceDataSource Operation
public virtual DeleteApplicationReferenceDataSourceResponse DeleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a reference data source configuration from the specified SQL-based Kinesis
/// Data Analytics application's configuration.
///
///
///
/// If the application is running, Kinesis Data Analytics immediately removes the in-application
/// table that you created using the AddApplicationReferenceDataSource operation.
///
///
///
/// Container for the necessary parameters to execute the DeleteApplicationReferenceDataSource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationReferenceDataSource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationReferenceDataSource Operation
public virtual Task DeleteApplicationReferenceDataSourceAsync(DeleteApplicationReferenceDataSourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationSnapshot
///
/// Deletes a snapshot of application state.
///
/// Container for the necessary parameters to execute the DeleteApplicationSnapshot service method.
///
/// The response from the DeleteApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DeleteApplicationSnapshot Operation
public virtual DeleteApplicationSnapshotResponse DeleteApplicationSnapshot(DeleteApplicationSnapshotRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationSnapshotResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a snapshot of application state.
///
/// Container for the necessary parameters to execute the DeleteApplicationSnapshot service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DeleteApplicationSnapshot Operation
public virtual Task DeleteApplicationSnapshotAsync(DeleteApplicationSnapshotRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationSnapshotResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteApplicationVpcConfiguration
///
/// Removes a VPC configuration from a Kinesis Data Analytics application.
///
/// Container for the necessary parameters to execute the DeleteApplicationVpcConfiguration service method.
///
/// The response from the DeleteApplicationVpcConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationVpcConfiguration Operation
public virtual DeleteApplicationVpcConfigurationResponse DeleteApplicationVpcConfiguration(DeleteApplicationVpcConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationVpcConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationVpcConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes a VPC configuration from a Kinesis Data Analytics application.
///
/// Container for the necessary parameters to execute the DeleteApplicationVpcConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteApplicationVpcConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DeleteApplicationVpcConfiguration Operation
public virtual Task DeleteApplicationVpcConfigurationAsync(DeleteApplicationVpcConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationVpcConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationVpcConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeApplication
///
/// Returns information about a specific Kinesis Data Analytics application.
///
///
///
/// If you want to retrieve a list of all applications in your account, use the ListApplications
/// operation.
///
///
/// Container for the necessary parameters to execute the DescribeApplication service method.
///
/// The response from the DescribeApplication service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DescribeApplication Operation
public virtual DescribeApplicationResponse DescribeApplication(DescribeApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns information about a specific Kinesis Data Analytics application.
///
///
///
/// If you want to retrieve a list of all applications in your account, use the ListApplications
/// operation.
///
///
/// Container for the necessary parameters to execute the DescribeApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeApplication service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for DescribeApplication Operation
public virtual Task DescribeApplicationAsync(DescribeApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeApplicationSnapshot
///
/// Returns information about a snapshot of application state data.
///
/// Container for the necessary parameters to execute the DescribeApplicationSnapshot service method.
///
/// The response from the DescribeApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DescribeApplicationSnapshot Operation
public virtual DescribeApplicationSnapshotResponse DescribeApplicationSnapshot(DescribeApplicationSnapshotRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationSnapshotResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns information about a snapshot of application state data.
///
/// Container for the necessary parameters to execute the DescribeApplicationSnapshot service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeApplicationSnapshot service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DescribeApplicationSnapshot Operation
public virtual Task DescribeApplicationSnapshotAsync(DescribeApplicationSnapshotRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationSnapshotRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationSnapshotResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeApplicationVersion
///
/// Provides a detailed description of a specified version of the application. To see
/// a list of all the versions of an application, invoke the ListApplicationVersions
/// operation.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the DescribeApplicationVersion service method.
///
/// The response from the DescribeApplicationVersion service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DescribeApplicationVersion Operation
public virtual DescribeApplicationVersionResponse DescribeApplicationVersion(DescribeApplicationVersionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationVersionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides a detailed description of a specified version of the application. To see
/// a list of all the versions of an application, invoke the ListApplicationVersions
/// operation.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the DescribeApplicationVersion service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeApplicationVersion service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DescribeApplicationVersion Operation
public virtual Task DescribeApplicationVersionAsync(DescribeApplicationVersionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationVersionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DiscoverInputSchema
///
/// Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample
/// records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose
/// delivery stream) or Amazon S3 object. In the response, the operation returns the inferred
/// schema and also the sample records that the operation used to infer the schema.
///
///
///
/// You can use the inferred schema when configuring a streaming source for your application.
/// When you create an application using the Kinesis Data Analytics console, the console
/// uses this operation to infer a schema and show it in the console user interface.
///
///
/// Container for the necessary parameters to execute the DiscoverInputSchema service method.
///
/// The response from the DiscoverInputSchema service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// Discovery failed to get a record from the streaming source because of the Kinesis
/// Streams ProvisionedThroughputExceededException. For more information,
/// see GetRecords
/// in the Amazon Kinesis Streams API Reference.
///
///
/// The service cannot complete the request.
///
///
/// The data format is not valid. Kinesis Data Analytics cannot detect the schema for
/// the given streaming source.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DiscoverInputSchema Operation
public virtual DiscoverInputSchemaResponse DiscoverInputSchema(DiscoverInputSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DiscoverInputSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DiscoverInputSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample
/// records on the specified streaming source (Kinesis data stream or Kinesis Data Firehose
/// delivery stream) or Amazon S3 object. In the response, the operation returns the inferred
/// schema and also the sample records that the operation used to infer the schema.
///
///
///
/// You can use the inferred schema when configuring a streaming source for your application.
/// When you create an application using the Kinesis Data Analytics console, the console
/// uses this operation to infer a schema and show it in the console user interface.
///
///
/// Container for the necessary parameters to execute the DiscoverInputSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DiscoverInputSchema service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// Discovery failed to get a record from the streaming source because of the Kinesis
/// Streams ProvisionedThroughputExceededException. For more information,
/// see GetRecords
/// in the Amazon Kinesis Streams API Reference.
///
///
/// The service cannot complete the request.
///
///
/// The data format is not valid. Kinesis Data Analytics cannot detect the schema for
/// the given streaming source.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for DiscoverInputSchema Operation
public virtual Task DiscoverInputSchemaAsync(DiscoverInputSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DiscoverInputSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DiscoverInputSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListApplications
///
/// Returns a list of Kinesis Data Analytics applications in your account. For each application,
/// the response includes the application name, Amazon Resource Name (ARN), and status.
///
///
///
///
/// If you want detailed information about a specific application, use DescribeApplication.
///
///
/// Container for the necessary parameters to execute the ListApplications service method.
///
/// The response from the ListApplications service method, as returned by KinesisAnalyticsV2.
///
/// The request JSON is not valid for the operation.
///
/// REST API Reference for ListApplications Operation
public virtual ListApplicationsResponse ListApplications(ListApplicationsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns a list of Kinesis Data Analytics applications in your account. For each application,
/// the response includes the application name, Amazon Resource Name (ARN), and status.
///
///
///
///
/// If you want detailed information about a specific application, use DescribeApplication.
///
///
/// Container for the necessary parameters to execute the ListApplications service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListApplications service method, as returned by KinesisAnalyticsV2.
///
/// The request JSON is not valid for the operation.
///
/// REST API Reference for ListApplications Operation
public virtual Task ListApplicationsAsync(ListApplicationsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListApplicationSnapshots
///
/// Lists information about the current application snapshots.
///
/// Container for the necessary parameters to execute the ListApplicationSnapshots service method.
///
/// The response from the ListApplicationSnapshots service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for ListApplicationSnapshots Operation
public virtual ListApplicationSnapshotsResponse ListApplicationSnapshots(ListApplicationSnapshotsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationSnapshotsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationSnapshotsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists information about the current application snapshots.
///
/// Container for the necessary parameters to execute the ListApplicationSnapshots service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListApplicationSnapshots service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for ListApplicationSnapshots Operation
public virtual Task ListApplicationSnapshotsAsync(ListApplicationSnapshotsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationSnapshotsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationSnapshotsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListApplicationVersions
///
/// Lists all the versions for the specified application, including versions that were
/// rolled back. The response also includes a summary of the configuration associated
/// with each version.
///
///
///
/// To get the complete description of a specific application version, invoke the DescribeApplicationVersion
/// operation.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the ListApplicationVersions service method.
///
/// The response from the ListApplicationVersions service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for ListApplicationVersions Operation
public virtual ListApplicationVersionsResponse ListApplicationVersions(ListApplicationVersionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationVersionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists all the versions for the specified application, including versions that were
/// rolled back. The response also includes a summary of the configuration associated
/// with each version.
///
///
///
/// To get the complete description of a specific application version, invoke the DescribeApplicationVersion
/// operation.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the ListApplicationVersions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListApplicationVersions service method, as returned by KinesisAnalyticsV2.
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for ListApplicationVersions Operation
public virtual Task ListApplicationVersionsAsync(ListApplicationVersionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationVersionsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListTagsForResource
///
/// Retrieves the list of key-value tags assigned to the application. For more information,
/// see Using
/// Tagging.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
/// 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);
}
///
/// Retrieves the list of key-value tags assigned to the application. For more information,
/// see Using
/// Tagging.
///
/// 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 KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// Specified application can't be found.
///
/// 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 RollbackApplication
///
/// Reverts the application to the previous running version. You can roll back an application
/// if you suspect it is stuck in a transient status.
///
///
///
/// You can roll back an application only if it is in the UPDATING or AUTOSCALING
/// status.
///
///
///
/// When you rollback an application, it loads state data from the last successful snapshot.
/// If the application has no snapshots, Kinesis Data Analytics rejects the rollback request.
///
///
///
/// This action is not supported for Kinesis Data Analytics for SQL applications.
///
///
/// Container for the necessary parameters to execute the RollbackApplication service method.
///
/// The response from the RollbackApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for RollbackApplication Operation
public virtual RollbackApplicationResponse RollbackApplication(RollbackApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = RollbackApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = RollbackApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Reverts the application to the previous running version. You can roll back an application
/// if you suspect it is stuck in a transient status.
///
///
///
/// You can roll back an application only if it is in the UPDATING or AUTOSCALING
/// status.
///
///
///
/// When you rollback an application, it loads state data from the last successful snapshot.
/// If the application has no snapshots, Kinesis Data Analytics rejects the rollback request.
///
///
///
/// This action is not supported for Kinesis Data Analytics for SQL applications.
///
///
/// Container for the necessary parameters to execute the RollbackApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the RollbackApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for RollbackApplication Operation
public virtual Task RollbackApplicationAsync(RollbackApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = RollbackApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = RollbackApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartApplication
///
/// Starts the specified Kinesis Data Analytics application. After creating an application,
/// you must exclusively call this operation to start your application.
///
/// Container for the necessary parameters to execute the StartApplication service method.
///
/// The response from the StartApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for StartApplication Operation
public virtual StartApplicationResponse StartApplication(StartApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Starts the specified Kinesis Data Analytics application. After creating an application,
/// you must exclusively call this operation to start your application.
///
/// Container for the necessary parameters to execute the StartApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for StartApplication Operation
public virtual Task StartApplicationAsync(StartApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StopApplication
///
/// Stops the application from processing data. You can stop an application only if it
/// is in the running status, unless you set the Force parameter to true.
///
///
///
/// You can use the DescribeApplication operation to find the application status.
///
///
///
///
/// Kinesis Data Analytics takes a snapshot when the application is stopped, unless Force
/// is set to true.
///
///
/// Container for the necessary parameters to execute the StopApplication service method.
///
/// The response from the StopApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for StopApplication Operation
public virtual StopApplicationResponse StopApplication(StopApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Stops the application from processing data. You can stop an application only if it
/// is in the running status, unless you set the Force parameter to true.
///
///
///
/// You can use the DescribeApplication operation to find the application status.
///
///
///
///
/// Kinesis Data Analytics takes a snapshot when the application is stopped, unless Force
/// is set to true.
///
///
/// Container for the necessary parameters to execute the StopApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StopApplication service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for StopApplication Operation
public virtual Task StopApplicationAsync(StopApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StopApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TagResource
///
/// Adds one or more key-value tags to a Kinesis Data Analytics application. Note that
/// the maximum number of application tags includes system tags. The maximum number of
/// user-defined application tags is 50. For more information, see Using
/// Tagging.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
/// 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);
}
///
/// Adds one or more key-value tags to a Kinesis Data Analytics application. Note that
/// the maximum number of application tags includes system tags. The maximum number of
/// user-defined application tags is 50. For more information, see Using
/// Tagging.
///
/// 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 KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
/// 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 one or more tags from a Kinesis Data Analytics application. For more information,
/// see Using
/// Tagging.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
/// 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 one or more tags from a Kinesis Data Analytics application. For more information,
/// see Using
/// Tagging.
///
/// 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 KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// Application created with too many tags, or too many tags added to an application.
/// Note that the maximum number of application tags includes system tags. The maximum
/// number of user-defined application tags is 50.
///
/// 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
#region UpdateApplication
///
/// Updates an existing Kinesis Data Analytics application. Using this operation, you
/// can update application code, input configuration, and output configuration.
///
///
///
/// Kinesis Data Analytics updates the ApplicationVersionId each time you
/// update your application.
///
///
///
/// You cannot update the RuntimeEnvironment of an existing application.
/// If you need to update an application's RuntimeEnvironment, you must delete
/// the application and create it again.
///
///
///
/// Container for the necessary parameters to execute the UpdateApplication service method.
///
/// The response from the UpdateApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for UpdateApplication Operation
public virtual UpdateApplicationResponse UpdateApplication(UpdateApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates an existing Kinesis Data Analytics application. Using this operation, you
/// can update application code, input configuration, and output configuration.
///
///
///
/// Kinesis Data Analytics updates the ApplicationVersionId each time you
/// update your application.
///
///
///
/// You cannot update the RuntimeEnvironment of an existing application.
/// If you need to update an application's RuntimeEnvironment, you must delete
/// the application and create it again.
///
///
///
/// Container for the necessary parameters to execute the UpdateApplication service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateApplication service method, as returned by KinesisAnalyticsV2.
///
/// The user-provided application code (query) is not valid. This can be a simple syntax
/// error.
///
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The user-provided application configuration is not valid.
///
///
/// The specified input parameter value is not valid.
///
///
/// The request JSON is not valid for the operation.
///
///
/// The number of allowed resources has been exceeded.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
/// REST API Reference for UpdateApplication Operation
public virtual Task UpdateApplicationAsync(UpdateApplicationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateApplicationMaintenanceConfiguration
///
/// Updates the maintenance configuration of the Kinesis Data Analytics application.
///
///
///
/// You can invoke this operation on an application that is in one of the two following
/// states: READY or RUNNING. If you invoke it when the application
/// is in a state other than these two states, it throws a ResourceInUseException.
/// The service makes use of the updated configuration the next time it schedules maintenance
/// for the application. If you invoke this operation after the service schedules maintenance,
/// the service will apply the configuration update the next time it schedules maintenance
/// for the application. This means that you might not see the maintenance configuration
/// update applied to the maintenance process that follows a successful invocation of
/// this operation, but to the following maintenance process instead.
///
///
///
/// To see the current maintenance configuration of your application, invoke the DescribeApplication
/// operation.
///
///
///
/// For information about application maintenance, see Kinesis
/// Data Analytics for Apache Flink Maintenance.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the UpdateApplicationMaintenanceConfiguration service method.
///
/// The response from the UpdateApplicationMaintenanceConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for UpdateApplicationMaintenanceConfiguration Operation
public virtual UpdateApplicationMaintenanceConfigurationResponse UpdateApplicationMaintenanceConfiguration(UpdateApplicationMaintenanceConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationMaintenanceConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationMaintenanceConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the maintenance configuration of the Kinesis Data Analytics application.
///
///
///
/// You can invoke this operation on an application that is in one of the two following
/// states: READY or RUNNING. If you invoke it when the application
/// is in a state other than these two states, it throws a ResourceInUseException.
/// The service makes use of the updated configuration the next time it schedules maintenance
/// for the application. If you invoke this operation after the service schedules maintenance,
/// the service will apply the configuration update the next time it schedules maintenance
/// for the application. This means that you might not see the maintenance configuration
/// update applied to the maintenance process that follows a successful invocation of
/// this operation, but to the following maintenance process instead.
///
///
///
/// To see the current maintenance configuration of your application, invoke the DescribeApplication
/// operation.
///
///
///
/// For information about application maintenance, see Kinesis
/// Data Analytics for Apache Flink Maintenance.
///
///
///
/// This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink.
///
///
///
/// Container for the necessary parameters to execute the UpdateApplicationMaintenanceConfiguration service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateApplicationMaintenanceConfiguration service method, as returned by KinesisAnalyticsV2.
///
/// Exception thrown as a result of concurrent modifications to an application. This error
/// can be the result of attempting to modify an application without using the current
/// application ID.
///
///
/// The specified input parameter value is not valid.
///
///
/// The application is not available for this operation.
///
///
/// Specified application can't be found.
///
///
/// The request was rejected because a specified parameter is not supported or a specified
/// resource is not valid for this operation.
///
/// REST API Reference for UpdateApplicationMaintenanceConfiguration Operation
public virtual Task UpdateApplicationMaintenanceConfigurationAsync(UpdateApplicationMaintenanceConfigurationRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationMaintenanceConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationMaintenanceConfigurationResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}