lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.22.0 vs lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.23.0
- old
+ new
@@ -382,12 +382,12 @@
def add_application_cloud_watch_logging_option(params = {}, options = {})
req = build_request(:add_application_cloud_watch_logging_option, params)
req.send_request(options)
end
- # Adds a streaming source to your SQL-based Amazon Kinesis Data
- # Analytics application.
+ # 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.
#
@@ -493,18 +493,18 @@
def add_application_input(params = {}, options = {})
req = build_request(:add_application_input, params)
req.send_request(options)
end
- # Adds an InputProcessingConfiguration to an SQL-based Kinesis Data
+ # 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 [AWS Lambda][1].
#
#
#
- # [1]: https://aws.amazon.com/documentation/lambda/
+ # [1]: https://docs.aws.amazon.com/lambda/
#
# @option params [required, String] :application_name
# The name of the application to which you want to add the input
# processing configuration.
#
@@ -558,12 +558,12 @@
def add_application_input_processing_configuration(params = {}, options = {})
req = build_request(:add_application_input_processing_configuration, params)
req.send_request(options)
end
- # Adds an external destination to your SQL-based Amazon Kinesis Data
- # Analytics application.
+ # 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 AWS Lambda function), you add the relevant
@@ -648,12 +648,12 @@
def add_application_output(params = {}, options = {})
req = build_request(:add_application_output, params)
req.send_request(options)
end
- # Adds a reference data source to an existing SQL-based Amazon Kinesis
- # Data Analytics application.
+ # 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
@@ -761,15 +761,14 @@
#
# @option params [required, String] :application_name
# The name of an existing application.
#
# @option params [required, Integer] :current_application_version_id
- # The version of the application to which you want to add the input
- # processing configuration. You can use the DescribeApplication
- # operation to get the current application version. If the version
- # specified is not the current version, the
- # `ConcurrentModificationException` is returned.
+ # The version of the application to which you want to add the VPC
+ # configuration. You can use the DescribeApplication operation to get
+ # the current application version. If the version specified is not the
+ # current version, the `ConcurrentModificationException` is returned.
#
# @option params [required, Types::VpcConfiguration] :vpc_configuration
# Description of the VPC to add to the application.
#
# @return [Types::AddApplicationVpcConfigurationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
@@ -807,12 +806,12 @@
def add_application_vpc_configuration(params = {}, options = {})
req = build_request(:add_application_vpc_configuration, params)
req.send_request(options)
end
- # Creates an Amazon Kinesis Data Analytics application. For information
- # about creating a Kinesis Data Analytics application, see [Creating an
+ # Creates a Kinesis Data Analytics application. For information about
+ # creating a Kinesis Data Analytics application, see [Creating an
# Application][1].
#
#
#
# [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/java/getting-started.html
@@ -822,12 +821,12 @@
#
# @option params [String] :application_description
# A summary description of the application.
#
# @option params [required, String] :runtime_environment
- # The runtime environment for the application (`SQL-1.0` or
- # `FLINK-1_6`).
+ # The runtime environment for the application (`SQL-1.0`, `FLINK-1_6`,
+ # or `FLINK-1_8`).
#
# @option params [required, String] :service_execution_role
# The IAM role used by the application to access Kinesis data streams,
# Kinesis Data Firehose delivery streams, Amazon S3 objects, and other
# external resources.
@@ -1022,11 +1021,11 @@
# resp.application_detail.application_arn #=> String
# resp.application_detail.application_description #=> String
# resp.application_detail.application_name #=> String
# resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8"
# resp.application_detail.service_execution_role #=> String
- # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING"
+ # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING"
# resp.application_detail.application_version_id #=> Integer
# resp.application_detail.create_timestamp #=> Time
# resp.application_detail.last_update_timestamp #=> Time
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions #=> Array
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions[0].input_id #=> String
@@ -1175,12 +1174,12 @@
def delete_application(params = {}, options = {})
req = build_request(:delete_application, params)
req.send_request(options)
end
- # Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data
- # Analytics application.
+ # Deletes an Amazon CloudWatch log stream from an Kinesis Data Analytics
+ # application.
#
# @option params [required, String] :application_name
# The application name.
#
# @option params [required, Integer] :current_application_version_id
@@ -1266,12 +1265,12 @@
req = build_request(:delete_application_input_processing_configuration, params)
req.send_request(options)
end
# Deletes the output destination configuration from your SQL-based
- # Amazon Kinesis Data Analytics application's configuration. Kinesis
- # Data Analytics will no longer write data from the corresponding
+ # 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.
#
# @option params [required, String] :application_name
# The application name.
#
@@ -1315,11 +1314,11 @@
req = build_request(:delete_application_output, params)
req.send_request(options)
end
# Deletes a reference data source configuration from the specified
- # SQL-based Amazon Kinesis Data Analytics application's configuration.
+ # 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.
#
@@ -1434,11 +1433,11 @@
def delete_application_vpc_configuration(params = {}, options = {})
req = build_request(:delete_application_vpc_configuration, params)
req.send_request(options)
end
- # Returns information about a specific Amazon Kinesis Data Analytics
+ # 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.
#
@@ -1465,11 +1464,11 @@
# resp.application_detail.application_arn #=> String
# resp.application_detail.application_description #=> String
# resp.application_detail.application_name #=> String
# resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8"
# resp.application_detail.service_execution_role #=> String
- # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING"
+ # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING"
# resp.application_detail.application_version_id #=> Integer
# resp.application_detail.create_timestamp #=> Time
# resp.application_detail.last_update_timestamp #=> Time
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions #=> Array
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions[0].input_id #=> String
@@ -1601,16 +1600,15 @@
def describe_application_snapshot(params = {}, options = {})
req = build_request(:describe_application_snapshot, params)
req.send_request(options)
end
- # Infers a schema for an SQL-based Amazon 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.
+ # 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.
@@ -1730,13 +1728,13 @@
def list_application_snapshots(params = {}, options = {})
req = build_request(:list_application_snapshots, params)
req.send_request(options)
end
- # Returns a list of Amazon Kinesis Data Analytics applications in your
- # account. For each application, the response includes the application
- # name, Amazon Resource Name (ARN), and status.
+ # 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.
#
# @option params [Integer] :limit
@@ -1767,11 +1765,11 @@
# @example Response structure
#
# resp.application_summaries #=> Array
# resp.application_summaries[0].application_name #=> String
# resp.application_summaries[0].application_arn #=> String
- # resp.application_summaries[0].application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING"
+ # resp.application_summaries[0].application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING"
# resp.application_summaries[0].application_version_id #=> Integer
# resp.application_summaries[0].runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8"
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplications AWS API Documentation
@@ -1816,11 +1814,11 @@
def list_tags_for_resource(params = {}, options = {})
req = build_request(:list_tags_for_resource, params)
req.send_request(options)
end
- # Starts the specified Amazon Kinesis Data Analytics application. After
+ # Starts the specified Kinesis Data Analytics application. After
# creating an application, you must exclusively call this operation to
# start your application.
#
# @option params [required, String] :application_name
# The name of the application.
@@ -1868,16 +1866,29 @@
# DescribeApplication operation to find the application state.
#
# @option params [required, String] :application_name
# The name of the running application to stop.
#
+ # @option params [Boolean] :force
+ # Set to `true` to force the application to stop. If you set `Force` to
+ # `true`, Kinesis Data Analytics stops the application without taking a
+ # snapshot.
+ #
+ # You can only force stop a Flink-based Kinesis Data Analytics
+ # application. You can't force stop a SQL-based Kinesis Data Analytics
+ # application.
+ #
+ # The application must be in the `STARTING`, `UPDATING`, `STOPPING`,
+ # `AUTOSCALING`, or `RUNNING` state.
+ #
# @return [Struct] Returns an empty {Seahorse::Client::Response response}.
#
# @example Request syntax with placeholder values
#
# resp = client.stop_application({
# application_name: "ApplicationName", # required
+ # force: false,
# })
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/StopApplication AWS API Documentation
#
# @overload stop_application(params = {})
@@ -1885,14 +1896,14 @@
def stop_application(params = {}, options = {})
req = build_request(:stop_application, params)
req.send_request(options)
end
- # 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][1].
+ # 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][1].
#
#
#
# [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-tagging.html
#
@@ -1923,20 +1934,20 @@
def tag_resource(params = {}, options = {})
req = build_request(:tag_resource, params)
req.send_request(options)
end
- # Removes one or more tags from a Kinesis Analytics application. For
- # more information, see [Using Tagging][1].
+ # Removes one or more tags from a Kinesis Data Analytics application.
+ # For more information, see [Using Tagging][1].
#
#
#
# [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-tagging.html
#
# @option params [required, String] :resource_arn
- # The ARN of the Kinesis Analytics application from which to remove the
- # tags.
+ # The ARN of the Kinesis Data Analytics application from which to remove
+ # the tags.
#
# @option params [required, Array<String>] :tag_keys
# A list of keys of tags to remove from the specified application.
#
# @return [Struct] Returns an empty {Seahorse::Client::Response response}.
@@ -1955,17 +1966,23 @@
def untag_resource(params = {}, options = {})
req = build_request(:untag_resource, params)
req.send_request(options)
end
- # Updates an existing Amazon Kinesis Data Analytics application. Using
- # this operation, you can update application code, input configuration,
- # and output configuration.
+ # 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.
#
+ # <note markdown="1"> 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.
+ #
+ # </note>
+ #
# @option params [required, String] :application_name
# The name of the application to update.
#
# @option params [required, Integer] :current_application_version_id
# The current application version ID. You can retrieve the application
@@ -2165,11 +2182,11 @@
# resp.application_detail.application_arn #=> String
# resp.application_detail.application_description #=> String
# resp.application_detail.application_name #=> String
# resp.application_detail.runtime_environment #=> String, one of "SQL-1_0", "FLINK-1_6", "FLINK-1_8"
# resp.application_detail.service_execution_role #=> String
- # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING"
+ # resp.application_detail.application_status #=> String, one of "DELETING", "STARTING", "STOPPING", "READY", "RUNNING", "UPDATING", "AUTOSCALING", "FORCE_STOPPING"
# resp.application_detail.application_version_id #=> Integer
# resp.application_detail.create_timestamp #=> Time
# resp.application_detail.last_update_timestamp #=> Time
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions #=> Array
# resp.application_detail.application_configuration_description.sql_application_configuration_description.input_descriptions[0].input_id #=> String
@@ -2278,10 +2295,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-kinesisanalyticsv2'
- context[:gem_version] = '1.22.0'
+ context[:gem_version] = '1.23.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated