/*
* 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.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();
}
///
/// Customize the pipeline
///
///
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
///
///
///
/// 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.
///
/// 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 AddApplicationCloudWatchLoggingOptionResponse AddApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the AddApplicationCloudWatchLoggingOption operation.
///
///
/// Container for the necessary parameters to execute the AddApplicationCloudWatchLoggingOption operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndAddApplicationCloudWatchLoggingOption
/// operation.
/// REST API Reference for AddApplicationCloudWatchLoggingOption Operation
public virtual IAsyncResult BeginAddApplicationCloudWatchLoggingOption(AddApplicationCloudWatchLoggingOptionRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the AddApplicationCloudWatchLoggingOption operation.
///
///
/// The IAsyncResult returned by the call to BeginAddApplicationCloudWatchLoggingOption.
///
/// Returns a AddApplicationCloudWatchLoggingOptionResult from KinesisAnalytics.
/// REST API Reference for AddApplicationCloudWatchLoggingOption Operation
public virtual AddApplicationCloudWatchLoggingOptionResponse EndAddApplicationCloudWatchLoggingOption(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region AddApplicationInput
///
///
///
/// 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.
///
/// 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 AddApplicationInputResponse AddApplicationInput(AddApplicationInputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the AddApplicationInput operation.
///
///
/// Container for the necessary parameters to execute the AddApplicationInput operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndAddApplicationInput
/// operation.
/// REST API Reference for AddApplicationInput Operation
public virtual IAsyncResult BeginAddApplicationInput(AddApplicationInputRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the AddApplicationInput operation.
///
///
/// The IAsyncResult returned by the call to BeginAddApplicationInput.
///
/// Returns a AddApplicationInputResult from KinesisAnalytics.
/// REST API Reference for AddApplicationInput Operation
public virtual AddApplicationInputResponse EndAddApplicationInput(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region AddApplicationInputProcessingConfiguration
///
///
///
/// 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.
///
/// 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 AddApplicationInputProcessingConfigurationResponse AddApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the AddApplicationInputProcessingConfiguration operation.
///
///
/// Container for the necessary parameters to execute the AddApplicationInputProcessingConfiguration operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndAddApplicationInputProcessingConfiguration
/// operation.
/// REST API Reference for AddApplicationInputProcessingConfiguration Operation
public virtual IAsyncResult BeginAddApplicationInputProcessingConfiguration(AddApplicationInputProcessingConfigurationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the AddApplicationInputProcessingConfiguration operation.
///
///
/// The IAsyncResult returned by the call to BeginAddApplicationInputProcessingConfiguration.
///
/// Returns a AddApplicationInputProcessingConfigurationResult from KinesisAnalytics.
/// REST API Reference for AddApplicationInputProcessingConfiguration Operation
public virtual AddApplicationInputProcessingConfigurationResponse EndAddApplicationInputProcessingConfiguration(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region AddApplicationOutput
///
///
///
/// 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.
///
/// 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 AddApplicationOutputResponse AddApplicationOutput(AddApplicationOutputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationOutputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the AddApplicationOutput operation.
///
///
/// Container for the necessary parameters to execute the AddApplicationOutput operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndAddApplicationOutput
/// operation.
/// REST API Reference for AddApplicationOutput Operation
public virtual IAsyncResult BeginAddApplicationOutput(AddApplicationOutputRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationOutputResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the AddApplicationOutput operation.
///
///
/// The IAsyncResult returned by the call to BeginAddApplicationOutput.
///
/// Returns a AddApplicationOutputResult from KinesisAnalytics.
/// REST API Reference for AddApplicationOutput Operation
public virtual AddApplicationOutputResponse EndAddApplicationOutput(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region AddApplicationReferenceDataSource
///
///
///
/// 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.
///
/// 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 AddApplicationReferenceDataSourceResponse AddApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the AddApplicationReferenceDataSource operation.
///
///
/// Container for the necessary parameters to execute the AddApplicationReferenceDataSource operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndAddApplicationReferenceDataSource
/// operation.
/// REST API Reference for AddApplicationReferenceDataSource Operation
public virtual IAsyncResult BeginAddApplicationReferenceDataSource(AddApplicationReferenceDataSourceRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = AddApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = AddApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the AddApplicationReferenceDataSource operation.
///
///
/// The IAsyncResult returned by the call to BeginAddApplicationReferenceDataSource.
///
/// Returns a AddApplicationReferenceDataSourceResult from KinesisAnalytics.
/// REST API Reference for AddApplicationReferenceDataSource Operation
public virtual AddApplicationReferenceDataSourceResponse EndAddApplicationReferenceDataSource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region CreateApplication
///
///
///
/// 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.
///
/// 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 CreateApplicationResponse CreateApplication(CreateApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the CreateApplication operation.
///
///
/// Container for the necessary parameters to execute the CreateApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndCreateApplication
/// operation.
/// REST API Reference for CreateApplication Operation
public virtual IAsyncResult BeginCreateApplication(CreateApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the CreateApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginCreateApplication.
///
/// Returns a CreateApplicationResult from KinesisAnalytics.
/// REST API Reference for CreateApplication Operation
public virtual CreateApplicationResponse EndCreateApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteApplication
///
///
///
/// 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.
///
/// 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 DeleteApplicationResponse DeleteApplication(DeleteApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteApplication operation.
///
///
/// Container for the necessary parameters to execute the DeleteApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteApplication
/// operation.
/// REST API Reference for DeleteApplication Operation
public virtual IAsyncResult BeginDeleteApplication(DeleteApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteApplication.
///
/// Returns a DeleteApplicationResult from KinesisAnalytics.
/// REST API Reference for DeleteApplication Operation
public virtual DeleteApplicationResponse EndDeleteApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteApplicationCloudWatchLoggingOption
///
///
///
/// 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.
///
/// 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 DeleteApplicationCloudWatchLoggingOptionResponse DeleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteApplicationCloudWatchLoggingOption operation.
///
///
/// Container for the necessary parameters to execute the DeleteApplicationCloudWatchLoggingOption operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteApplicationCloudWatchLoggingOption
/// operation.
/// REST API Reference for DeleteApplicationCloudWatchLoggingOption Operation
public virtual IAsyncResult BeginDeleteApplicationCloudWatchLoggingOption(DeleteApplicationCloudWatchLoggingOptionRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationCloudWatchLoggingOptionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationCloudWatchLoggingOptionResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteApplicationCloudWatchLoggingOption operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteApplicationCloudWatchLoggingOption.
///
/// Returns a DeleteApplicationCloudWatchLoggingOptionResult from KinesisAnalytics.
/// REST API Reference for DeleteApplicationCloudWatchLoggingOption Operation
public virtual DeleteApplicationCloudWatchLoggingOptionResponse EndDeleteApplicationCloudWatchLoggingOption(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteApplicationInputProcessingConfiguration
///
///
///
/// 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.
///
/// 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 DeleteApplicationInputProcessingConfigurationResponse DeleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteApplicationInputProcessingConfiguration operation.
///
///
/// Container for the necessary parameters to execute the DeleteApplicationInputProcessingConfiguration operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteApplicationInputProcessingConfiguration
/// operation.
/// REST API Reference for DeleteApplicationInputProcessingConfiguration Operation
public virtual IAsyncResult BeginDeleteApplicationInputProcessingConfiguration(DeleteApplicationInputProcessingConfigurationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationInputProcessingConfigurationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationInputProcessingConfigurationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteApplicationInputProcessingConfiguration operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteApplicationInputProcessingConfiguration.
///
/// Returns a DeleteApplicationInputProcessingConfigurationResult from KinesisAnalytics.
/// REST API Reference for DeleteApplicationInputProcessingConfiguration Operation
public virtual DeleteApplicationInputProcessingConfigurationResponse EndDeleteApplicationInputProcessingConfiguration(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteApplicationOutput
///
///
///
/// 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.
///
/// 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 DeleteApplicationOutputResponse DeleteApplicationOutput(DeleteApplicationOutputRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationOutputResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteApplicationOutput operation.
///
///
/// Container for the necessary parameters to execute the DeleteApplicationOutput operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteApplicationOutput
/// operation.
/// REST API Reference for DeleteApplicationOutput Operation
public virtual IAsyncResult BeginDeleteApplicationOutput(DeleteApplicationOutputRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationOutputRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationOutputResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteApplicationOutput operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteApplicationOutput.
///
/// Returns a DeleteApplicationOutputResult from KinesisAnalytics.
/// REST API Reference for DeleteApplicationOutput Operation
public virtual DeleteApplicationOutputResponse EndDeleteApplicationOutput(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DeleteApplicationReferenceDataSource
///
///
///
/// 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.
///
/// 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 DeleteApplicationReferenceDataSourceResponse DeleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DeleteApplicationReferenceDataSource operation.
///
///
/// Container for the necessary parameters to execute the DeleteApplicationReferenceDataSource operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDeleteApplicationReferenceDataSource
/// operation.
/// REST API Reference for DeleteApplicationReferenceDataSource Operation
public virtual IAsyncResult BeginDeleteApplicationReferenceDataSource(DeleteApplicationReferenceDataSourceRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteApplicationReferenceDataSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteApplicationReferenceDataSourceResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DeleteApplicationReferenceDataSource operation.
///
///
/// The IAsyncResult returned by the call to BeginDeleteApplicationReferenceDataSource.
///
/// Returns a DeleteApplicationReferenceDataSourceResult from KinesisAnalytics.
/// REST API Reference for DeleteApplicationReferenceDataSource Operation
public virtual DeleteApplicationReferenceDataSourceResponse EndDeleteApplicationReferenceDataSource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DescribeApplication
///
///
///
/// 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.
///
/// 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 DescribeApplicationResponse DescribeApplication(DescribeApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DescribeApplication operation.
///
///
/// Container for the necessary parameters to execute the DescribeApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDescribeApplication
/// operation.
/// REST API Reference for DescribeApplication Operation
public virtual IAsyncResult BeginDescribeApplication(DescribeApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DescribeApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginDescribeApplication.
///
/// Returns a DescribeApplicationResult from KinesisAnalytics.
/// REST API Reference for DescribeApplication Operation
public virtual DescribeApplicationResponse EndDescribeApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region DiscoverInputSchema
///
///
///
/// 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.
///
/// 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 DiscoverInputSchemaResponse DiscoverInputSchema(DiscoverInputSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DiscoverInputSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DiscoverInputSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the DiscoverInputSchema operation.
///
///
/// Container for the necessary parameters to execute the DiscoverInputSchema operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndDiscoverInputSchema
/// operation.
/// REST API Reference for DiscoverInputSchema Operation
public virtual IAsyncResult BeginDiscoverInputSchema(DiscoverInputSchemaRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = DiscoverInputSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DiscoverInputSchemaResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the DiscoverInputSchema operation.
///
///
/// The IAsyncResult returned by the call to BeginDiscoverInputSchema.
///
/// Returns a DiscoverInputSchemaResult from KinesisAnalytics.
/// REST API Reference for DiscoverInputSchema Operation
public virtual DiscoverInputSchemaResponse EndDiscoverInputSchema(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region ListApplications
///
///
///
/// 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.
///
/// The response from the ListApplications service method, as returned by KinesisAnalytics.
/// 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);
}
///
/// Initiates the asynchronous execution of the ListApplications operation.
///
///
/// Container for the necessary parameters to execute the ListApplications operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndListApplications
/// operation.
/// REST API Reference for ListApplications Operation
public virtual IAsyncResult BeginListApplications(ListApplicationsRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListApplicationsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListApplicationsResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the ListApplications operation.
///
///
/// The IAsyncResult returned by the call to BeginListApplications.
///
/// Returns a ListApplicationsResult from KinesisAnalytics.
/// REST API Reference for ListApplications Operation
public virtual ListApplicationsResponse EndListApplications(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#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 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 ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the ListTagsForResource operation.
///
///
/// Container for the necessary parameters to execute the ListTagsForResource operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndListTagsForResource
/// operation.
/// REST API Reference for ListTagsForResource Operation
public virtual IAsyncResult BeginListTagsForResource(ListTagsForResourceRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the ListTagsForResource operation.
///
///
/// The IAsyncResult returned by the call to BeginListTagsForResource.
///
/// Returns a ListTagsForResourceResult from KinesisAnalytics.
/// REST API Reference for ListTagsForResource Operation
public virtual ListTagsForResourceResponse EndListTagsForResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region StartApplication
///
///
///
/// 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.
///
/// 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 StartApplicationResponse StartApplication(StartApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the StartApplication operation.
///
///
/// Container for the necessary parameters to execute the StartApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndStartApplication
/// operation.
/// REST API Reference for StartApplication Operation
public virtual IAsyncResult BeginStartApplication(StartApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the StartApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginStartApplication.
///
/// Returns a StartApplicationResult from KinesisAnalytics.
/// REST API Reference for StartApplication Operation
public virtual StartApplicationResponse EndStartApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region StopApplication
///
///
///
/// 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.
///
/// 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 StopApplicationResponse StopApplication(StopApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the StopApplication operation.
///
///
/// Container for the necessary parameters to execute the StopApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndStopApplication
/// operation.
/// REST API Reference for StopApplication Operation
public virtual IAsyncResult BeginStopApplication(StopApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the StopApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginStopApplication.
///
/// Returns a StopApplicationResult from KinesisAnalytics.
/// REST API Reference for StopApplication Operation
public virtual StopApplicationResponse EndStopApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region TagResource
///
/// 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.
///
/// 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 TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the TagResource operation.
///
///
/// Container for the necessary parameters to execute the TagResource operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndTagResource
/// operation.
/// REST API Reference for TagResource Operation
public virtual IAsyncResult BeginTagResource(TagResourceRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the TagResource operation.
///
///
/// The IAsyncResult returned by the call to BeginTagResource.
///
/// Returns a TagResourceResult from KinesisAnalytics.
/// REST API Reference for TagResource Operation
public virtual TagResourceResponse EndTagResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region UntagResource
///
/// 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.
///
/// 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 UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the UntagResource operation.
///
///
/// Container for the necessary parameters to execute the UntagResource operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndUntagResource
/// operation.
/// REST API Reference for UntagResource Operation
public virtual IAsyncResult BeginUntagResource(UntagResourceRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the UntagResource operation.
///
///
/// The IAsyncResult returned by the call to BeginUntagResource.
///
/// Returns a UntagResourceResult from KinesisAnalytics.
/// REST API Reference for UntagResource Operation
public virtual UntagResourceResponse EndUntagResource(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
#region UpdateApplication
///
///
///
/// 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.
///
/// 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 UpdateApplicationResponse UpdateApplication(UpdateApplicationRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Initiates the asynchronous execution of the UpdateApplication operation.
///
///
/// Container for the necessary parameters to execute the UpdateApplication operation on AmazonKinesisAnalyticsClient.
/// An AsyncCallback delegate that is invoked when the operation completes.
/// A user-defined state object that is passed to the callback procedure. Retrieve this object from within the callback
/// procedure using the AsyncState property.
///
/// An IAsyncResult that can be used to poll or wait for results, or both; this value is also needed when invoking EndUpdateApplication
/// operation.
/// REST API Reference for UpdateApplication Operation
public virtual IAsyncResult BeginUpdateApplication(UpdateApplicationRequest request, AsyncCallback callback, object state)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateApplicationRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateApplicationResponseUnmarshaller.Instance;
return BeginInvoke(request, options, callback, state);
}
///
/// Finishes the asynchronous execution of the UpdateApplication operation.
///
///
/// The IAsyncResult returned by the call to BeginUpdateApplication.
///
/// Returns a UpdateApplicationResult from KinesisAnalytics.
/// REST API Reference for UpdateApplication Operation
public virtual UpdateApplicationResponse EndUpdateApplication(IAsyncResult asyncResult)
{
return EndInvoke(asyncResult);
}
#endregion
}
}