/* * Copyright 2018-2023 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. */ package com.amazonaws.services.kinesisanalytics; import javax.annotation.Generated; import com.amazonaws.services.kinesisanalytics.model.*; /** * Interface for accessing Kinesis Analytics asynchronously. Each asynchronous method will return a Java Future object * representing the asynchronous operation; overloads which accept an {@code AsyncHandler} can be used to receive * notification when an asynchronous operation completes. *

* Note: Do not directly implement this interface, new methods are added to it regularly. Extend from * {@link com.amazonaws.services.kinesisanalytics.AbstractAmazonKinesisAnalyticsAsync} instead. *

* 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. *

*/ @Generated("com.amazonaws:aws-java-sdk-code-generator") public interface AmazonKinesisAnalyticsAsync extends AmazonKinesisAnalytics { /** * *

* 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. *

* * @param addApplicationCloudWatchLoggingOptionRequest * @return A Java Future containing the result of the AddApplicationCloudWatchLoggingOption operation returned by * the service. * @sample AmazonKinesisAnalyticsAsync.AddApplicationCloudWatchLoggingOption * @see AWS API Documentation */ java.util.concurrent.Future addApplicationCloudWatchLoggingOptionAsync( AddApplicationCloudWatchLoggingOptionRequest addApplicationCloudWatchLoggingOptionRequest); /** * *

* *

* * @param addApplicationCloudWatchLoggingOptionRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the AddApplicationCloudWatchLoggingOption operation returned by * the service. * @sample AmazonKinesisAnalyticsAsyncHandler.AddApplicationCloudWatchLoggingOption * @see AWS API Documentation */ java.util.concurrent.Future addApplicationCloudWatchLoggingOptionAsync( AddApplicationCloudWatchLoggingOptionRequest addApplicationCloudWatchLoggingOptionRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param addApplicationInputRequest * @return A Java Future containing the result of the AddApplicationInput operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.AddApplicationInput * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputAsync(AddApplicationInputRequest addApplicationInputRequest); /** * *

* *

* Adds a streaming source to your Amazon Kinesis application. For conceptual information, see Configuring Application * Input. *

* This operation requires permissions to perform the kinesisanalytics:AddApplicationInput action. *

* * @param addApplicationInputRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the AddApplicationInput operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.AddApplicationInput * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputAsync(AddApplicationInputRequest addApplicationInputRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param addApplicationInputProcessingConfigurationRequest * @return A Java Future containing the result of the AddApplicationInputProcessingConfiguration operation returned * by the service. * @sample AmazonKinesisAnalyticsAsync.AddApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputProcessingConfigurationAsync( AddApplicationInputProcessingConfigurationRequest addApplicationInputProcessingConfigurationRequest); /** * *

* *

* * @param addApplicationInputProcessingConfigurationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the AddApplicationInputProcessingConfiguration operation returned * by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.AddApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputProcessingConfigurationAsync( AddApplicationInputProcessingConfigurationRequest addApplicationInputProcessingConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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). *

* 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. *

* * @param addApplicationOutputRequest * @return A Java Future containing the result of the AddApplicationOutput operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.AddApplicationOutput * @see AWS API Documentation */ java.util.concurrent.Future addApplicationOutputAsync(AddApplicationOutputRequest addApplicationOutputRequest); /** * *

* *

* Adds an external destination to your Amazon Kinesis Analytics application. *

* 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. *

* * @param addApplicationOutputRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the AddApplicationOutput operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.AddApplicationOutput * @see AWS API Documentation */ java.util.concurrent.Future addApplicationOutputAsync(AddApplicationOutputRequest addApplicationOutputRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param addApplicationReferenceDataSourceRequest * @return A Java Future containing the result of the AddApplicationReferenceDataSource operation returned by the * service. * @sample AmazonKinesisAnalyticsAsync.AddApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future addApplicationReferenceDataSourceAsync( AddApplicationReferenceDataSourceRequest addApplicationReferenceDataSourceRequest); /** * *

* *

* Adds a reference data source to an existing application. *

* 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. *

* * @param addApplicationReferenceDataSourceRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the AddApplicationReferenceDataSource operation returned by the * service. * @sample AmazonKinesisAnalyticsAsyncHandler.AddApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future addApplicationReferenceDataSourceAsync( AddApplicationReferenceDataSourceRequest addApplicationReferenceDataSourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param createApplicationRequest * TBD * @return A Java Future containing the result of the CreateApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.CreateApplication * @see AWS API Documentation */ java.util.concurrent.Future createApplicationAsync(CreateApplicationRequest createApplicationRequest); /** * *

* *

* 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. *

* For introductory exercises to create an Amazon Kinesis Analytics application, see Getting Started. *

* * @param createApplicationRequest * TBD * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the CreateApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.CreateApplication * @see AWS API Documentation */ java.util.concurrent.Future createApplicationAsync(CreateApplicationRequest createApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param deleteApplicationRequest * @return A Java Future containing the result of the DeleteApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.DeleteApplication * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationAsync(DeleteApplicationRequest deleteApplicationRequest); /** * *

* *

* This operation requires permissions to perform the kinesisanalytics:DeleteApplication action. *

* * @param deleteApplicationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DeleteApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DeleteApplication * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationAsync(DeleteApplicationRequest deleteApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param deleteApplicationCloudWatchLoggingOptionRequest * @return A Java Future containing the result of the DeleteApplicationCloudWatchLoggingOption operation returned by * the service. * @sample AmazonKinesisAnalyticsAsync.DeleteApplicationCloudWatchLoggingOption * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationCloudWatchLoggingOptionAsync( DeleteApplicationCloudWatchLoggingOptionRequest deleteApplicationCloudWatchLoggingOptionRequest); /** * *

* *

* * @param deleteApplicationCloudWatchLoggingOptionRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DeleteApplicationCloudWatchLoggingOption operation returned by * the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DeleteApplicationCloudWatchLoggingOption * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationCloudWatchLoggingOptionAsync( DeleteApplicationCloudWatchLoggingOptionRequest deleteApplicationCloudWatchLoggingOptionRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* Deletes an InputProcessingConfiguration from an input. *

* * @param deleteApplicationInputProcessingConfigurationRequest * @return A Java Future containing the result of the DeleteApplicationInputProcessingConfiguration operation * returned by the service. * @sample AmazonKinesisAnalyticsAsync.DeleteApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationInputProcessingConfigurationAsync( DeleteApplicationInputProcessingConfigurationRequest deleteApplicationInputProcessingConfigurationRequest); /** * *

* *

* Deletes an InputProcessingConfiguration from an input. *

* * @param deleteApplicationInputProcessingConfigurationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DeleteApplicationInputProcessingConfiguration operation * returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DeleteApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationInputProcessingConfigurationAsync( DeleteApplicationInputProcessingConfigurationRequest deleteApplicationInputProcessingConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param deleteApplicationOutputRequest * @return A Java Future containing the result of the DeleteApplicationOutput operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.DeleteApplicationOutput * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationOutputAsync(DeleteApplicationOutputRequest deleteApplicationOutputRequest); /** * *

* *

* This operation requires permissions to perform the kinesisanalytics:DeleteApplicationOutput action. *

* * @param deleteApplicationOutputRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DeleteApplicationOutput operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DeleteApplicationOutput * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationOutputAsync(DeleteApplicationOutputRequest deleteApplicationOutputRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param deleteApplicationReferenceDataSourceRequest * @return A Java Future containing the result of the DeleteApplicationReferenceDataSource operation returned by the * service. * @sample AmazonKinesisAnalyticsAsync.DeleteApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationReferenceDataSourceAsync( DeleteApplicationReferenceDataSourceRequest deleteApplicationReferenceDataSourceRequest); /** * *

* *

* 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. *

* * @param deleteApplicationReferenceDataSourceRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DeleteApplicationReferenceDataSource operation returned by the * service. * @sample AmazonKinesisAnalyticsAsyncHandler.DeleteApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationReferenceDataSourceAsync( DeleteApplicationReferenceDataSourceRequest deleteApplicationReferenceDataSourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param describeApplicationRequest * @return A Java Future containing the result of the DescribeApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.DescribeApplication * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationAsync(DescribeApplicationRequest describeApplicationRequest); /** * *

* *

* 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. *

* * @param describeApplicationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DescribeApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DescribeApplication * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationAsync(DescribeApplicationRequest describeApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param discoverInputSchemaRequest * @return A Java Future containing the result of the DiscoverInputSchema operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.DiscoverInputSchema * @see AWS API Documentation */ java.util.concurrent.Future discoverInputSchemaAsync(DiscoverInputSchemaRequest discoverInputSchemaRequest); /** * *

* *

* This operation requires permissions to perform the kinesisanalytics:DiscoverInputSchema action. *

* * @param discoverInputSchemaRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the DiscoverInputSchema operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.DiscoverInputSchema * @see AWS API Documentation */ java.util.concurrent.Future discoverInputSchemaAsync(DiscoverInputSchemaRequest discoverInputSchemaRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param listApplicationsRequest * @return A Java Future containing the result of the ListApplications operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.ListApplications * @see AWS API Documentation */ java.util.concurrent.Future listApplicationsAsync(ListApplicationsRequest listApplicationsRequest); /** * *

* *

* If you want detailed information about a specific application, use DescribeApplication. *

* This operation requires permissions to perform the kinesisanalytics:ListApplications action. *

* * @param listApplicationsRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the ListApplications operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.ListApplications * @see AWS API Documentation */ java.util.concurrent.Future listApplicationsAsync(ListApplicationsRequest listApplicationsRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging. *

* * @param listTagsForResourceRequest * @return A Java Future containing the result of the ListTagsForResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.ListTagsForResource * @see AWS API Documentation */ java.util.concurrent.Future listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest); /** *

* Retrieves the list of key-value tags assigned to the application. For more information, see Using Tagging. *

* * @param listTagsForResourceRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the ListTagsForResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.ListTagsForResource * @see AWS API Documentation */ java.util.concurrent.Future listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param startApplicationRequest * @return A Java Future containing the result of the StartApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.StartApplication * @see AWS API Documentation */ java.util.concurrent.Future startApplicationAsync(StartApplicationRequest startApplicationRequest); /** * *

* *

* 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. *

* * @param startApplicationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the StartApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.StartApplication * @see AWS API Documentation */ java.util.concurrent.Future startApplicationAsync(StartApplicationRequest startApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param stopApplicationRequest * @return A Java Future containing the result of the StopApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.StopApplication * @see AWS API Documentation */ java.util.concurrent.Future stopApplicationAsync(StopApplicationRequest stopApplicationRequest); /** * *

* *

* This operation requires permissions to perform the kinesisanalytics:StopApplication action. *

* * @param stopApplicationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the StopApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.StopApplication * @see AWS API Documentation */ java.util.concurrent.Future stopApplicationAsync(StopApplicationRequest stopApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* 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. *

* * @param tagResourceRequest * @return A Java Future containing the result of the TagResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.TagResource * @see AWS * API Documentation */ java.util.concurrent.Future tagResourceAsync(TagResourceRequest tagResourceRequest); /** *

* * @param tagResourceRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the TagResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.TagResource * @see AWS * API Documentation */ java.util.concurrent.Future tagResourceAsync(TagResourceRequest tagResourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Removes one or more tags from a Kinesis Analytics application. For more information, see Using Tagging. *

* * @param untagResourceRequest * @return A Java Future containing the result of the UntagResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.UntagResource * @see AWS * API Documentation */ java.util.concurrent.Future untagResourceAsync(UntagResourceRequest untagResourceRequest); /** *

* Removes one or more tags from a Kinesis Analytics application. For more information, see Using Tagging. *

* * @param untagResourceRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the UntagResource operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.UntagResource * @see AWS * API Documentation */ java.util.concurrent.Future untagResourceAsync(UntagResourceRequest untagResourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** * *

* *

* 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. *

* * @param updateApplicationRequest * @return A Java Future containing the result of the UpdateApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsync.UpdateApplication * @see AWS API Documentation */ java.util.concurrent.Future updateApplicationAsync(UpdateApplicationRequest updateApplicationRequest); /** * *

* *

* 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. *

* * @param updateApplicationRequest * @param asyncHandler * Asynchronous callback handler for events in the lifecycle of the request. Users can provide an * implementation of the callback methods in this interface to receive notification of successful or * unsuccessful completion of the operation. * @return A Java Future containing the result of the UpdateApplication operation returned by the service. * @sample AmazonKinesisAnalyticsAsyncHandler.UpdateApplication * @see AWS API Documentation */ java.util.concurrent.Future updateApplicationAsync(UpdateApplicationRequest updateApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); }