/* * 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 kinesisanalytics-2015-08-14.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.KinesisAnalytics.Model; using Amazon.KinesisAnalytics.Model.Internal.MarshallTransformations; using Amazon.KinesisAnalytics.Internal; using Amazon.Runtime; using Amazon.Runtime.Internal; using Amazon.Runtime.Internal.Auth; using Amazon.Runtime.Internal.Transform; namespace Amazon.KinesisAnalytics { /// /// Implementation for accessing KinesisAnalytics /// /// Amazon Kinesis Analytics /// /// Overview /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// This is the Amazon Kinesis Analytics v1 API Reference. The Amazon Kinesis Analytics /// Developer Guide provides additional information. /// /// public partial class AmazonKinesisAnalyticsClient : AmazonServiceClient, IAmazonKinesisAnalytics { private static IServiceMetadata serviceMetadata = new AmazonKinesisAnalyticsMetadata(); #region Constructors /// /// Constructs AmazonKinesisAnalyticsClient 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 AmazonKinesisAnalyticsClient() : base(FallbackCredentialsFactory.GetCredentials(), new AmazonKinesisAnalyticsConfig()) { } /// /// Constructs AmazonKinesisAnalyticsClient 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 AmazonKinesisAnalyticsClient(RegionEndpoint region) : base(FallbackCredentialsFactory.GetCredentials(), new AmazonKinesisAnalyticsConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonKinesisAnalyticsClient 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 AmazonKinesisAnalyticsClient Configuration Object public AmazonKinesisAnalyticsClient(AmazonKinesisAnalyticsConfig config) : base(FallbackCredentialsFactory.GetCredentials(config), config){} /// /// Constructs AmazonKinesisAnalyticsClient with AWS Credentials /// /// AWS Credentials public AmazonKinesisAnalyticsClient(AWSCredentials credentials) : this(credentials, new AmazonKinesisAnalyticsConfig()) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Credentials /// /// AWS Credentials /// The region to connect. public AmazonKinesisAnalyticsClient(AWSCredentials credentials, RegionEndpoint region) : this(credentials, new AmazonKinesisAnalyticsConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Credentials and an /// AmazonKinesisAnalyticsClient Configuration object. /// /// AWS Credentials /// The AmazonKinesisAnalyticsClient Configuration Object public AmazonKinesisAnalyticsClient(AWSCredentials credentials, AmazonKinesisAnalyticsConfig clientConfig) : base(credentials, clientConfig) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key public AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonKinesisAnalyticsConfig()) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// The region to connect. public AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonKinesisAnalyticsConfig() {RegionEndpoint=region}) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Access Key ID, AWS Secret Key and an /// AmazonKinesisAnalyticsClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// The AmazonKinesisAnalyticsClient Configuration Object public AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonKinesisAnalyticsConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, clientConfig) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token public AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKinesisAnalyticsConfig()) { } /// /// Constructs AmazonKinesisAnalyticsClient 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 AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonKinesisAnalyticsConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonKinesisAnalyticsClient with AWS Access Key ID, AWS Secret Key and an /// AmazonKinesisAnalyticsClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The AmazonKinesisAnalyticsClient Configuration Object public AmazonKinesisAnalyticsClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonKinesisAnalyticsConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig) { } #endregion #region Overrides /// /// Creates the signer for the service. /// protected override AbstractAWSSigner CreateSigner() { return new AWS4Signer(); } /// /// Customizes the runtime pipeline. /// /// Runtime pipeline for the current client. protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline) { pipeline.RemoveHandler(); pipeline.AddHandlerAfter(new AmazonKinesisAnalyticsEndpointResolver()); } /// /// 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 internal virtual AddApplicationCloudWatchLoggingOptionResponse AddApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = AddApplicationCloudWatchLoggingOptionRequestMarshaller.Instance; options.ResponseUnmarshaller = AddApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Adds a CloudWatch log stream to monitor application configuration errors. For more /// information about using CloudWatch log streams with Amazon Kinesis Analytics applications, /// see Working /// with Amazon CloudWatch Logs. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual AddApplicationInputResponse AddApplicationInput(AddApplicationInputRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = AddApplicationInputRequestMarshaller.Instance; options.ResponseUnmarshaller = AddApplicationInputResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Adds a streaming source to your Amazon Kinesis application. For conceptual information, /// see Configuring /// Application Input. /// /// /// /// You can add a streaming source either 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. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:AddApplicationInput /// action. /// /// /// 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 KinesisAnalytics. /// /// User-provided application code (query) is invalid. This can be a simple syntax error. /// /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual AddApplicationInputProcessingConfigurationResponse AddApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = AddApplicationInputProcessingConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = AddApplicationInputProcessingConfigurationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Adds an InputProcessingConfiguration /// to an application. An input processor preprocesses records on the input stream before /// the application's SQL code executes. Currently, the only input processor available /// is AWS 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual AddApplicationOutputResponse AddApplicationOutput(AddApplicationOutputRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = AddApplicationOutputRequestMarshaller.Instance; options.ResponseUnmarshaller = AddApplicationOutputResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Adds an external destination to your Amazon Kinesis Analytics application. /// /// /// /// If you want Amazon Kinesis Analytics to deliver data from an in-application stream /// within your application to an external destination (such as an Amazon Kinesis stream, /// an Amazon Kinesis Firehose delivery stream, or an AWS 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. For more /// information, see Understanding /// Application Output (Destination). /// /// /// /// 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. /// /// /// /// For the limits on the number of application inputs and outputs you can configure, /// see Limits. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:AddApplicationOutput /// action. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual AddApplicationReferenceDataSourceResponse AddApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = AddApplicationReferenceDataSourceRequestMarshaller.Instance; options.ResponseUnmarshaller = AddApplicationReferenceDataSourceResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Adds a reference data source to an existing application. /// /// /// /// Amazon Kinesis 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 Amazon S3 object /// maps to columns in the resulting in-application table. /// /// /// /// For conceptual information, see Configuring /// Application Input. For the limits on data sources you can add to your application, /// see Limits. /// /// /// /// /// This operation requires permissions to perform the kinesisanalytics:AddApplicationOutput /// action. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 CreateApplication internal virtual CreateApplicationResponse CreateApplication(CreateApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Creates an Amazon Kinesis Analytics application. You can configure each application /// with one streaming source as input, application code to process the input, and up /// to three destinations where you want Amazon Kinesis Analytics to write the output /// data from your application. For an overview, see How /// it Works. /// /// /// /// In the input configuration, you map the streaming source to an in-application stream, /// which you can think of as a constantly updating table. In the mapping, you must provide /// a schema for the in-application stream and map each data column in the in-application /// stream to a data element in the streaming source. /// /// /// /// Your application code is one or more SQL statements that read input data, transform /// it, and generate output. Your application code can create one or more SQL artifacts /// like SQL streams or pumps. /// /// /// /// In the output configuration, you can configure the application to write data from /// in-application streams created in your applications to up to three destinations. /// /// /// /// To read data from your source stream or write data to destination streams, Amazon /// Kinesis Analytics needs your permissions. You grant these permissions by creating /// IAM roles. This operation requires permissions to perform the kinesisanalytics:CreateApplication /// action. /// /// /// /// For introductory exercises to create an Amazon Kinesis Analytics application, see /// Getting /// Started. /// /// /// 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 KinesisAnalytics. /// /// User-provided application code (query) is invalid. This can be a simple syntax error. /// /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// Exceeded the number of applications allowed. /// /// /// 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. /// /// 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 DeleteApplication internal virtual DeleteApplicationResponse DeleteApplication(DeleteApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Deletes the specified application. Amazon Kinesis Analytics halts application execution /// and deletes the application, including any application artifacts (such as in-application /// streams, reference table, and application code). /// /// /// /// This operation requires permissions to perform the kinesisanalytics:DeleteApplication /// action. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// 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 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 internal virtual DeleteApplicationCloudWatchLoggingOptionResponse DeleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteApplicationCloudWatchLoggingOptionRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Deletes a CloudWatch log stream from an application. For more information about using /// CloudWatch log streams with Amazon Kinesis Analytics applications, see Working /// with Amazon CloudWatch Logs. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual DeleteApplicationInputProcessingConfigurationResponse DeleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteApplicationInputProcessingConfigurationRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteApplicationInputProcessingConfigurationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual DeleteApplicationOutputResponse DeleteApplicationOutput(DeleteApplicationOutputRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteApplicationOutputRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteApplicationOutputResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Deletes output destination configuration from your application configuration. Amazon /// Kinesis Analytics will no longer write data from the corresponding in-application /// stream to the external output destination. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:DeleteApplicationOutput /// action. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual DeleteApplicationReferenceDataSourceResponse DeleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteApplicationReferenceDataSourceRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteApplicationReferenceDataSourceResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Deletes a reference data source configuration from the specified application configuration. /// /// /// /// If the application is running, Amazon Kinesis Analytics immediately removes the in-application /// table that you created using the AddApplicationReferenceDataSource /// operation. /// /// /// /// This operation requires permissions to perform the kinesisanalytics.DeleteApplicationReferenceDataSource /// action. /// /// /// 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 DescribeApplication internal virtual DescribeApplicationResponse DescribeApplication(DescribeApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Returns information about a specific Amazon Kinesis Analytics application. /// /// /// /// If you want to retrieve a list of all applications in your account, use the ListApplications /// operation. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:DescribeApplication /// action. You can use DescribeApplication to get the current application /// versionId, which you need to call other operations such as Update. /// /// /// 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 KinesisAnalytics. /// /// 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 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 DiscoverInputSchema internal virtual DiscoverInputSchemaResponse DiscoverInputSchema(DiscoverInputSchemaRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DiscoverInputSchemaRequestMarshaller.Instance; options.ResponseUnmarshaller = DiscoverInputSchemaResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Infers a schema by evaluating sample records on the specified streaming source (Amazon /// Kinesis stream or Amazon Kinesis Firehose delivery stream) or 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. /// For conceptual information, see Configuring /// Application Input. Note that when you create an application using the Amazon Kinesis /// Analytics console, the console uses this operation to infer a schema and show it in /// the console user interface. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:DiscoverInputSchema /// action. /// /// /// 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 KinesisAnalytics. /// /// Specified input parameter value is invalid. /// /// /// Discovery failed to get a record from the streaming source because of the Amazon Kinesis /// Streams ProvisionedThroughputExceededException. For more information, see GetRecords /// in the Amazon Kinesis Streams API Reference. /// /// /// The service is unavailable. Back off and retry the operation. /// /// /// Data format is not valid. Amazon Kinesis Analytics is not able to detect schema for /// the given streaming source. /// /// 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 internal virtual ListApplicationsResponse ListApplications(ListApplicationsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListApplicationsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListApplicationsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Returns a list of Amazon Kinesis Analytics applications in your account. For each /// application, the response includes the application name, Amazon Resource Name (ARN), /// and status. If the response returns the HasMoreApplications value as /// true, you can send another request by adding the ExclusiveStartApplicationName /// in the request body, and set the value of this to the last application name from the /// previous response. /// /// /// /// If you want detailed information about a specific application, use DescribeApplication. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:ListApplications /// action. /// /// /// 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 KinesisAnalytics. /// 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 ListTagsForResource internal 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 StartApplication internal virtual StartApplicationResponse StartApplication(StartApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = StartApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = StartApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Starts the specified Amazon Kinesis Analytics application. After creating an application, /// you must exclusively call this operation to start your application. /// /// /// /// After the application starts, it begins consuming the input data, processes it, and /// writes the output to the configured destination. /// /// /// /// The application status must be READY for you to start an application. /// You can get the application status in the console or using the DescribeApplication /// operation. /// /// /// /// After you start the application, you can stop the application from processing the /// input by calling the StopApplication /// operation. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:StartApplication /// action. /// /// /// 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 KinesisAnalytics. /// /// User-provided application configuration is not valid. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 internal virtual StopApplicationResponse StopApplication(StopApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = StopApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = StopApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Stops the application from processing input data. You can stop an application only /// if it is in the running state. You can use the DescribeApplication /// operation to find the application state. After the application is stopped, Amazon /// Kinesis Analytics stops reading data from the input, the application stops processing /// data, and there is no output written to the destination. /// /// /// /// This operation requires permissions to perform the kinesisanalytics:StopApplication /// action. /// /// /// 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 KinesisAnalytics. /// /// 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 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 internal 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 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 internal 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 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 KinesisAnalytics. /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 internal virtual UpdateApplicationResponse UpdateApplication(UpdateApplicationRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UpdateApplicationRequestMarshaller.Instance; options.ResponseUnmarshaller = UpdateApplicationResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// /// /// This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which /// only supports SQL applications. Version 2 of the API supports SQL and Java applications. /// For more information about version 2, see Amazon /// Kinesis Data Analytics API V2 Documentation. /// /// /// /// Updates an existing Amazon Kinesis Analytics application. Using this API, you can /// update application code, input configuration, and output configuration. /// /// /// /// Note that Amazon Kinesis Analytics updates the CurrentApplicationVersionId /// each time you update your application. /// /// /// /// This operation requires permission for the kinesisanalytics:UpdateApplication /// action. /// /// /// 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 KinesisAnalytics. /// /// User-provided application code (query) is invalid. This can be a simple syntax error. /// /// /// Exception thrown as a result of concurrent modification to an application. For example, /// two individuals attempting to edit the same application at the same time. /// /// /// Specified input parameter value is invalid. /// /// /// 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 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 } }