/* * 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.kinesisanalyticsv2; import javax.annotation.Generated; import com.amazonaws.services.kinesisanalyticsv2.model.*; /** * Interface for accessing Kinesis Analytics V2 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.kinesisanalyticsv2.AbstractAmazonKinesisAnalyticsV2Async} instead. *

*

*

* Amazon Kinesis Data Analytics is a fully managed service that you can use to process and analyze streaming data using * Java, SQL, or Scala. The service enables you to quickly author and run Java, SQL, or Scala code against streaming * sources to perform time series analytics, feed real-time dashboards, and create real-time metrics. *

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

* Adds an Amazon CloudWatch log stream to monitor application configuration errors. *

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

* Adds an Amazon CloudWatch log stream to monitor application configuration errors. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.AddApplicationCloudWatchLoggingOption * @see AWS API Documentation */ java.util.concurrent.Future addApplicationCloudWatchLoggingOptionAsync( AddApplicationCloudWatchLoggingOptionRequest addApplicationCloudWatchLoggingOptionRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Adds a streaming source to your SQL-based Kinesis Data Analytics application. *

*

* You can add a streaming source when you create an application, or you can use this operation to add a streaming * source after you create an application. For more information, see CreateApplication. *

*

* Any configuration update, including adding a streaming source using this operation, results in a new version of * the application. You can use the DescribeApplication operation to find the current application version. *

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

* Adds a streaming source to your SQL-based Kinesis Data Analytics application. *

*

* You can add a streaming source when you create an application, or you can use this operation to add a streaming * source after you create an application. For more information, see CreateApplication. *

*

* Any configuration update, including adding a streaming source using this operation, results in a new version of * the application. You can use the DescribeApplication operation to find the current application version. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.AddApplicationInput * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputAsync(AddApplicationInputRequest addApplicationInputRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor * pre-processes records on the input stream before the application's SQL code executes. Currently, the only input * processor available is Amazon Lambda. *

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

* Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor * pre-processes records on the input stream before the application's SQL code executes. Currently, the only input * processor available is Amazon Lambda. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.AddApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future addApplicationInputProcessingConfigurationAsync( AddApplicationInputProcessingConfigurationRequest addApplicationInputProcessingConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Adds an external destination to your SQL-based Kinesis Data Analytics application. *

*

* If you want Kinesis Data Analytics to deliver data from an in-application stream within your application to an * external destination (such as an Kinesis data stream, a Kinesis Data Firehose delivery stream, or an Amazon * Lambda function), you add the relevant configuration to your application using this operation. You can configure * one or more outputs for your application. Each output configuration maps an in-application stream and an external * destination. *

*

* You can use one of the output configurations to deliver data from your in-application error stream to an external * destination so that you can analyze the errors. *

*

* Any configuration update, including adding a streaming source using this operation, results in a new version of * the application. You can use the DescribeApplication operation to find the current application version. *

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

* Adds an external destination to your SQL-based Kinesis Data Analytics application. *

*

* If you want Kinesis Data Analytics to deliver data from an in-application stream within your application to an * external destination (such as an Kinesis data stream, a Kinesis Data Firehose delivery stream, or an Amazon * Lambda function), you add the relevant configuration to your application using this operation. You can configure * one or more outputs for your application. Each output configuration maps an in-application stream and an external * destination. *

*

* You can use one of the output configurations to deliver data from your in-application error stream to an external * destination so that you can analyze the errors. *

*

* Any configuration update, including adding a streaming source using this operation, results in a new version of * the application. You can use the DescribeApplication operation to find the current application version. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 SQL-based Kinesis Data Analytics application. *

*

* Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table * within your application. In the request, you provide the source (S3 bucket name and object key name), name of the * in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 * object maps to columns in the resulting in-application table. *

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

* Adds a reference data source to an existing SQL-based Kinesis Data Analytics application. *

*

* Kinesis Data Analytics reads reference data (that is, an Amazon S3 object) and creates an in-application table * within your application. In the request, you provide the source (S3 bucket name and object key name), name of the * in-application table to create, and the necessary mapping information that describes how data in an Amazon S3 * object maps to columns in the resulting in-application table. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.AddApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future addApplicationReferenceDataSourceAsync( AddApplicationReferenceDataSourceRequest addApplicationReferenceDataSourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and * access resources securely. *

*

* Note the following about VPC configurations for Kinesis Data Analytics applications: *

*
    *
  • *

    * VPC configurations are not supported for SQL applications. *

    *
    • *
  • *

    * When a VPC is added to a Kinesis Data Analytics application, the application can no longer be accessed from the * Internet directly. To enable Internet access to the application, add an Internet gateway to your VPC. *

    *
    • *
* * @param addApplicationVpcConfigurationRequest * @return A Java Future containing the result of the AddApplicationVpcConfiguration operation returned by the * service. * @sample AmazonKinesisAnalyticsV2Async.AddApplicationVpcConfiguration * @see AWS API Documentation */ java.util.concurrent.Future addApplicationVpcConfigurationAsync( AddApplicationVpcConfigurationRequest addApplicationVpcConfigurationRequest); /** *

* Adds a Virtual Private Cloud (VPC) configuration to the application. Applications can use VPCs to store and * access resources securely. *

*

* Note the following about VPC configurations for Kinesis Data Analytics applications: *

*
    *
  • *

    * VPC configurations are not supported for SQL applications. *

    *
    • *
  • *

    * When a VPC is added to a Kinesis Data Analytics application, the application can no longer be accessed from the * Internet directly. To enable Internet access to the application, add an Internet gateway to your VPC. *

    *
    • *
* * @param addApplicationVpcConfigurationRequest * @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 AddApplicationVpcConfiguration operation returned by the * service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.AddApplicationVpcConfiguration * @see AWS API Documentation */ java.util.concurrent.Future addApplicationVpcConfigurationAsync( AddApplicationVpcConfigurationRequest addApplicationVpcConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Creates a Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics * application, see Creating * an Application. *

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

* Creates a Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics * application, see Creating * an Application. *

* * @param createApplicationRequest * @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 AmazonKinesisAnalyticsV2AsyncHandler.CreateApplication * @see AWS API Documentation */ java.util.concurrent.Future createApplicationAsync(CreateApplicationRequest createApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Creates and returns a URL that you can use to connect to an application's extension. *

*

* The IAM role or user used to call this API defines the permissions to access the extension. After the presigned * URL is created, no additional permission is required to access this URL. IAM authorization policies for this API * are also enforced for every HTTP request that attempts to connect to the extension. *

*

* You control the amount of time that the URL will be valid using the * SessionExpirationDurationInSeconds parameter. If you do not provide this parameter, the returned URL * is valid for twelve hours. *

* *

* The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes to be valid. If * you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error. *

* * * @param createApplicationPresignedUrlRequest * @return A Java Future containing the result of the CreateApplicationPresignedUrl operation returned by the * service. * @sample AmazonKinesisAnalyticsV2Async.CreateApplicationPresignedUrl * @see AWS API Documentation */ java.util.concurrent.Future createApplicationPresignedUrlAsync( CreateApplicationPresignedUrlRequest createApplicationPresignedUrlRequest); /** *

* Creates and returns a URL that you can use to connect to an application's extension. *

*

* The IAM role or user used to call this API defines the permissions to access the extension. After the presigned * URL is created, no additional permission is required to access this URL. IAM authorization policies for this API * are also enforced for every HTTP request that attempts to connect to the extension. *

*

* You control the amount of time that the URL will be valid using the * SessionExpirationDurationInSeconds parameter. If you do not provide this parameter, the returned URL * is valid for twelve hours. *

* *

* The URL that you get from a call to CreateApplicationPresignedUrl must be used within 3 minutes to be valid. If * you first try to use the URL after the 3-minute limit expires, the service returns an HTTP 403 Forbidden error. *

* * * @param createApplicationPresignedUrlRequest * @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 CreateApplicationPresignedUrl operation returned by the * service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.CreateApplicationPresignedUrl * @see AWS API Documentation */ java.util.concurrent.Future createApplicationPresignedUrlAsync( CreateApplicationPresignedUrlRequest createApplicationPresignedUrlRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Creates a snapshot of the application's state data. *

* * @param createApplicationSnapshotRequest * @return A Java Future containing the result of the CreateApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.CreateApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future createApplicationSnapshotAsync( CreateApplicationSnapshotRequest createApplicationSnapshotRequest); /** *

* Creates a snapshot of the application's state data. *

* * @param createApplicationSnapshotRequest * @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 CreateApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.CreateApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future createApplicationSnapshotAsync( CreateApplicationSnapshotRequest createApplicationSnapshotRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Deletes the specified application. Kinesis Data Analytics halts application execution and deletes the * application. *

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

* Deletes the specified application. Kinesis Data Analytics halts application execution and deletes the * application. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.DeleteApplication * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationAsync(DeleteApplicationRequest deleteApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application. *

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

* Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics application. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 AmazonKinesisAnalyticsV2Async.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 AmazonKinesisAnalyticsV2AsyncHandler.DeleteApplicationInputProcessingConfiguration * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationInputProcessingConfigurationAsync( DeleteApplicationInputProcessingConfigurationRequest deleteApplicationInputProcessingConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's * configuration. Kinesis Data Analytics will no longer write data from the corresponding in-application stream to * the external output destination. *

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

* Deletes the output destination configuration from your SQL-based Kinesis Data Analytics application's * configuration. Kinesis Data Analytics will no longer write data from the corresponding in-application stream to * the external output destination. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 SQL-based Kinesis Data Analytics application's * configuration. *

*

* If the application is running, Kinesis Data Analytics immediately removes the in-application table that you * created using the AddApplicationReferenceDataSource operation. *

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

* Deletes a reference data source configuration from the specified SQL-based Kinesis Data Analytics application's * configuration. *

*

* If the application is running, Kinesis Data Analytics immediately removes the in-application table that you * created using the AddApplicationReferenceDataSource operation. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.DeleteApplicationReferenceDataSource * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationReferenceDataSourceAsync( DeleteApplicationReferenceDataSourceRequest deleteApplicationReferenceDataSourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Deletes a snapshot of application state. *

* * @param deleteApplicationSnapshotRequest * @return A Java Future containing the result of the DeleteApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.DeleteApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationSnapshotAsync( DeleteApplicationSnapshotRequest deleteApplicationSnapshotRequest); /** *

* Deletes a snapshot of application state. *

* * @param deleteApplicationSnapshotRequest * @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 DeleteApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.DeleteApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationSnapshotAsync( DeleteApplicationSnapshotRequest deleteApplicationSnapshotRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Removes a VPC configuration from a Kinesis Data Analytics application. *

* * @param deleteApplicationVpcConfigurationRequest * @return A Java Future containing the result of the DeleteApplicationVpcConfiguration operation returned by the * service. * @sample AmazonKinesisAnalyticsV2Async.DeleteApplicationVpcConfiguration * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationVpcConfigurationAsync( DeleteApplicationVpcConfigurationRequest deleteApplicationVpcConfigurationRequest); /** *

* Removes a VPC configuration from a Kinesis Data Analytics application. *

* * @param deleteApplicationVpcConfigurationRequest * @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 DeleteApplicationVpcConfiguration operation returned by the * service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.DeleteApplicationVpcConfiguration * @see AWS API Documentation */ java.util.concurrent.Future deleteApplicationVpcConfigurationAsync( DeleteApplicationVpcConfigurationRequest deleteApplicationVpcConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Returns information about a specific Kinesis Data Analytics application. *

*

* If you want to retrieve a list of all applications in your account, use the ListApplications operation. *

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

* Returns information about a specific Kinesis Data Analytics application. *

*

* If you want to retrieve a list of all applications in your account, use the ListApplications operation. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.DescribeApplication * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationAsync(DescribeApplicationRequest describeApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Returns information about a snapshot of application state data. *

* * @param describeApplicationSnapshotRequest * @return A Java Future containing the result of the DescribeApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.DescribeApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationSnapshotAsync( DescribeApplicationSnapshotRequest describeApplicationSnapshotRequest); /** *

* Returns information about a snapshot of application state data. *

* * @param describeApplicationSnapshotRequest * @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 DescribeApplicationSnapshot operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.DescribeApplicationSnapshot * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationSnapshotAsync( DescribeApplicationSnapshotRequest describeApplicationSnapshotRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Provides a detailed description of a specified version of the application. To see a list of all the versions of * an application, invoke the ListApplicationVersions operation. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param describeApplicationVersionRequest * @return A Java Future containing the result of the DescribeApplicationVersion operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.DescribeApplicationVersion * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationVersionAsync( DescribeApplicationVersionRequest describeApplicationVersionRequest); /** *

* Provides a detailed description of a specified version of the application. To see a list of all the versions of * an application, invoke the ListApplicationVersions operation. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param describeApplicationVersionRequest * @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 DescribeApplicationVersion operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.DescribeApplicationVersion * @see AWS API Documentation */ java.util.concurrent.Future describeApplicationVersionAsync( DescribeApplicationVersionRequest describeApplicationVersionRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified * streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the * response, the operation returns the inferred schema and also the sample records that the operation used to infer * the schema. *

*

* You can use the inferred schema when configuring a streaming source for your application. When you create an * application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show * it in the console user interface. *

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

* Infers a schema for a SQL-based Kinesis Data Analytics application by evaluating sample records on the specified * streaming source (Kinesis data stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In the * response, the operation returns the inferred schema and also the sample records that the operation used to infer * the schema. *

*

* You can use the inferred schema when configuring a streaming source for your application. When you create an * application using the Kinesis Data Analytics console, the console uses this operation to infer a schema and show * it in the console user interface. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.DiscoverInputSchema * @see AWS API Documentation */ java.util.concurrent.Future discoverInputSchemaAsync(DiscoverInputSchemaRequest discoverInputSchemaRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Lists information about the current application snapshots. *

* * @param listApplicationSnapshotsRequest * @return A Java Future containing the result of the ListApplicationSnapshots operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.ListApplicationSnapshots * @see AWS API Documentation */ java.util.concurrent.Future listApplicationSnapshotsAsync(ListApplicationSnapshotsRequest listApplicationSnapshotsRequest); /** *

* Lists information about the current application snapshots. *

* * @param listApplicationSnapshotsRequest * @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 ListApplicationSnapshots operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.ListApplicationSnapshots * @see AWS API Documentation */ java.util.concurrent.Future listApplicationSnapshotsAsync(ListApplicationSnapshotsRequest listApplicationSnapshotsRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Lists all the versions for the specified application, including versions that were rolled back. The response also * includes a summary of the configuration associated with each version. *

*

* To get the complete description of a specific application version, invoke the DescribeApplicationVersion * operation. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param listApplicationVersionsRequest * @return A Java Future containing the result of the ListApplicationVersions operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.ListApplicationVersions * @see AWS API Documentation */ java.util.concurrent.Future listApplicationVersionsAsync(ListApplicationVersionsRequest listApplicationVersionsRequest); /** *

* Lists all the versions for the specified application, including versions that were rolled back. The response also * includes a summary of the configuration associated with each version. *

*

* To get the complete description of a specific application version, invoke the DescribeApplicationVersion * operation. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param listApplicationVersionsRequest * @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 ListApplicationVersions operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.ListApplicationVersions * @see AWS API Documentation */ java.util.concurrent.Future listApplicationVersionsAsync(ListApplicationVersionsRequest listApplicationVersionsRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Returns a list of Kinesis Data Analytics applications in your account. For each application, the response * includes the application name, Amazon Resource Name (ARN), and status. *

*

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

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

* Returns a list of Kinesis Data Analytics applications in your account. For each application, the response * includes the application name, Amazon Resource Name (ARN), and status. *

*

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

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 AmazonKinesisAnalyticsV2Async.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 AmazonKinesisAnalyticsV2AsyncHandler.ListTagsForResource * @see AWS API Documentation */ java.util.concurrent.Future listTagsForResourceAsync(ListTagsForResourceRequest listTagsForResourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Reverts the application to the previous running version. You can roll back an application if you suspect it is * stuck in a transient status. *

*

* You can roll back an application only if it is in the UPDATING or AUTOSCALING status. *

*

* When you rollback an application, it loads state data from the last successful snapshot. If the application has * no snapshots, Kinesis Data Analytics rejects the rollback request. *

*

* This action is not supported for Kinesis Data Analytics for SQL applications. *

* * @param rollbackApplicationRequest * @return A Java Future containing the result of the RollbackApplication operation returned by the service. * @sample AmazonKinesisAnalyticsV2Async.RollbackApplication * @see AWS API Documentation */ java.util.concurrent.Future rollbackApplicationAsync(RollbackApplicationRequest rollbackApplicationRequest); /** *

* Reverts the application to the previous running version. You can roll back an application if you suspect it is * stuck in a transient status. *

*

* You can roll back an application only if it is in the UPDATING or AUTOSCALING status. *

*

* When you rollback an application, it loads state data from the last successful snapshot. If the application has * no snapshots, Kinesis Data Analytics rejects the rollback request. *

*

* This action is not supported for Kinesis Data Analytics for SQL applications. *

* * @param rollbackApplicationRequest * @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 RollbackApplication operation returned by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.RollbackApplication * @see AWS API Documentation */ java.util.concurrent.Future rollbackApplicationAsync(RollbackApplicationRequest rollbackApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Starts the specified Kinesis Data Analytics application. After creating an application, you must exclusively call * this operation to start your application. *

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

* Starts the specified Kinesis Data Analytics application. After creating an application, you must exclusively call * this operation to start your application. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.StartApplication * @see AWS API Documentation */ java.util.concurrent.Future startApplicationAsync(StartApplicationRequest startApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Stops the application from processing data. You can stop an application only if it is in the running status, * unless you set the Force parameter to true. *

*

* You can use the DescribeApplication operation to find the application status. *

*

* Kinesis Data Analytics takes a snapshot when the application is stopped, unless Force is set to * true. *

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

* Stops the application from processing data. You can stop an application only if it is in the running status, * unless you set the Force parameter to true. *

*

* You can use the DescribeApplication operation to find the application status. *

*

* Kinesis Data Analytics takes a snapshot when the application is stopped, unless Force is set to * true. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 Data Analytics application. Note that the maximum number of * application tags includes system tags. The maximum number of user-defined application tags is 50. For more * information, see Using * Tagging. *

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

* Adds one or more key-value tags to a Kinesis Data Analytics application. Note that the maximum number of * application tags includes system tags. The maximum number of user-defined application tags is 50. For more * information, see Using * Tagging. *

* * @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 AmazonKinesisAnalyticsV2AsyncHandler.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 Data 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 AmazonKinesisAnalyticsV2Async.UntagResource * @see AWS API Documentation */ java.util.concurrent.Future untagResourceAsync(UntagResourceRequest untagResourceRequest); /** *

* Removes one or more tags from a Kinesis Data 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 AmazonKinesisAnalyticsV2AsyncHandler.UntagResource * @see AWS API Documentation */ java.util.concurrent.Future untagResourceAsync(UntagResourceRequest untagResourceRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Updates an existing Kinesis Data Analytics application. Using this operation, you can update application code, * input configuration, and output configuration. *

*

* Kinesis Data Analytics updates the ApplicationVersionId each time you update your application. *

* *

* You cannot update the RuntimeEnvironment of an existing application. If you need to update an * application's RuntimeEnvironment, you must delete the application and create it again. *

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

* Updates an existing Kinesis Data Analytics application. Using this operation, you can update application code, * input configuration, and output configuration. *

*

* Kinesis Data Analytics updates the ApplicationVersionId each time you update your application. *

* *

* You cannot update the RuntimeEnvironment of an existing application. If you need to update an * application's RuntimeEnvironment, you must delete the application and create it again. *

* * * @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 AmazonKinesisAnalyticsV2AsyncHandler.UpdateApplication * @see AWS API Documentation */ java.util.concurrent.Future updateApplicationAsync(UpdateApplicationRequest updateApplicationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); /** *

* Updates the maintenance configuration of the Kinesis Data Analytics application. *

*

* You can invoke this operation on an application that is in one of the two following states: READY or * RUNNING. If you invoke it when the application is in a state other than these two states, it throws * a ResourceInUseException. The service makes use of the updated configuration the next time it * schedules maintenance for the application. If you invoke this operation after the service schedules maintenance, * the service will apply the configuration update the next time it schedules maintenance for the application. This * means that you might not see the maintenance configuration update applied to the maintenance process that follows * a successful invocation of this operation, but to the following maintenance process instead. *

*

* To see the current maintenance configuration of your application, invoke the DescribeApplication * operation. *

*

* For information about application maintenance, see Kinesis Data Analytics for * Apache Flink Maintenance. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param updateApplicationMaintenanceConfigurationRequest * @return A Java Future containing the result of the UpdateApplicationMaintenanceConfiguration operation returned * by the service. * @sample AmazonKinesisAnalyticsV2Async.UpdateApplicationMaintenanceConfiguration * @see AWS API Documentation */ java.util.concurrent.Future updateApplicationMaintenanceConfigurationAsync( UpdateApplicationMaintenanceConfigurationRequest updateApplicationMaintenanceConfigurationRequest); /** *

* Updates the maintenance configuration of the Kinesis Data Analytics application. *

*

* You can invoke this operation on an application that is in one of the two following states: READY or * RUNNING. If you invoke it when the application is in a state other than these two states, it throws * a ResourceInUseException. The service makes use of the updated configuration the next time it * schedules maintenance for the application. If you invoke this operation after the service schedules maintenance, * the service will apply the configuration update the next time it schedules maintenance for the application. This * means that you might not see the maintenance configuration update applied to the maintenance process that follows * a successful invocation of this operation, but to the following maintenance process instead. *

*

* To see the current maintenance configuration of your application, invoke the DescribeApplication * operation. *

*

* For information about application maintenance, see Kinesis Data Analytics for * Apache Flink Maintenance. *

* *

* This operation is supported only for Amazon Kinesis Data Analytics for Apache Flink. *

* * * @param updateApplicationMaintenanceConfigurationRequest * @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 UpdateApplicationMaintenanceConfiguration operation returned * by the service. * @sample AmazonKinesisAnalyticsV2AsyncHandler.UpdateApplicationMaintenanceConfiguration * @see AWS API Documentation */ java.util.concurrent.Future updateApplicationMaintenanceConfigurationAsync( UpdateApplicationMaintenanceConfigurationRequest updateApplicationMaintenanceConfigurationRequest, com.amazonaws.handlers.AsyncHandler asyncHandler); }