lib/aws-sdk-kinesisanalytics/client.rb in aws-sdk-kinesisanalytics-1.0.0 vs lib/aws-sdk-kinesisanalytics/client.rb in aws-sdk-kinesisanalytics-1.1.0
- old
+ new
@@ -225,20 +225,27 @@
# Current version of your Amazon Kinesis Analytics application. You can
# use the DescribeApplication operation to find the current application
# version.
#
# @option params [required, Types::Input] :input
+ # The Input to add.
#
# @return [Struct] Returns an empty {Seahorse::Client::Response response}.
#
# @example Request syntax with placeholder values
#
# resp = client.add_application_input({
# application_name: "ApplicationName", # required
# current_application_version_id: 1, # required
# input: { # required
# name_prefix: "InAppStreamName", # required
+ # input_processing_configuration: {
+ # input_lambda_processor: { # required
+ # resource_arn: "ResourceARN", # required
+ # role_arn: "RoleARN", # required
+ # },
+ # },
# kinesis_streams_input: {
# resource_arn: "ResourceARN", # required
# role_arn: "RoleARN", # required
# },
# kinesis_firehose_input: {
@@ -280,10 +287,63 @@
def add_application_input(params = {}, options = {})
req = build_request(:add_application_input, params)
req.send_request(options)
end
+ # 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][1].
+ #
+ #
+ #
+ # [1]: https://aws.amazon.com/documentation/lambda/
+ #
+ # @option params [required, String] :application_name
+ # Name of the application to which you want to add the input processing
+ # configuration.
+ #
+ # @option params [required, Integer] :current_application_version_id
+ # 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.
+ #
+ # @option params [required, String] :input_id
+ # The ID of the input configuration to which to add the input
+ # configuration. You can get a list of the input IDs for an application
+ # using the DescribeApplication operation.
+ #
+ # @option params [required, Types::InputProcessingConfiguration] :input_processing_configuration
+ # The InputProcessingConfiguration to add to the application.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.add_application_input_processing_configuration({
+ # application_name: "ApplicationName", # required
+ # current_application_version_id: 1, # required
+ # input_id: "Id", # required
+ # input_processing_configuration: { # required
+ # input_lambda_processor: { # required
+ # resource_arn: "ResourceARN", # required
+ # role_arn: "RoleARN", # required
+ # },
+ # },
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalytics-2015-08-14/AddApplicationInputProcessingConfiguration AWS API Documentation
+ #
+ # @overload add_application_input_processing_configuration(params = {})
+ # @param [Hash] params ({})
+ 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 Amazon Kinesis Analytics
# application.
#
# If you want Amazon Kinesis Analytics to deliver data from an
# in-application stream within your application to an external
@@ -569,10 +629,16 @@
# application_name: "ApplicationName", # required
# application_description: "ApplicationDescription",
# inputs: [
# {
# name_prefix: "InAppStreamName", # required
+ # input_processing_configuration: {
+ # input_lambda_processor: { # required
+ # resource_arn: "ResourceARN", # required
+ # role_arn: "RoleARN", # required
+ # },
+ # },
# kinesis_streams_input: {
# resource_arn: "ResourceARN", # required
# role_arn: "RoleARN", # required
# },
# kinesis_firehose_input: {
@@ -714,10 +780,42 @@
def delete_application_cloud_watch_logging_option(params = {}, options = {})
req = build_request(:delete_application_cloud_watch_logging_option, params)
req.send_request(options)
end
+ # Deletes an InputProcessingConfiguration from an input.
+ #
+ # @option params [required, String] :application_name
+ # The Kinesis Analytics application name.
+ #
+ # @option params [required, Integer] :current_application_version_id
+ # The version ID of the Kinesis Analytics application.
+ #
+ # @option params [required, String] :input_id
+ # The ID of the input configuration from which to delete the input
+ # configuration. You can get a list of the input IDs for an application
+ # using the DescribeApplication operation.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.delete_application_input_processing_configuration({
+ # application_name: "ApplicationName", # required
+ # current_application_version_id: 1, # required
+ # input_id: "Id", # required
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalytics-2015-08-14/DeleteApplicationInputProcessingConfiguration AWS API Documentation
+ #
+ # @overload delete_application_input_processing_configuration(params = {})
+ # @param [Hash] params ({})
+ def delete_application_input_processing_configuration(params = {}, options = {})
+ req = build_request(:delete_application_input_processing_configuration, params)
+ req.send_request(options)
+ end
+
# 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.
#
@@ -839,10 +937,12 @@
# resp.application_detail.input_descriptions #=> Array
# resp.application_detail.input_descriptions[0].input_id #=> String
# resp.application_detail.input_descriptions[0].name_prefix #=> String
# resp.application_detail.input_descriptions[0].in_app_stream_names #=> Array
# resp.application_detail.input_descriptions[0].in_app_stream_names[0] #=> String
+ # resp.application_detail.input_descriptions[0].input_processing_configuration_description.input_lambda_processor_description.resource_arn #=> String
+ # resp.application_detail.input_descriptions[0].input_processing_configuration_description.input_lambda_processor_description.role_arn #=> String
# resp.application_detail.input_descriptions[0].kinesis_streams_input_description.resource_arn #=> String
# resp.application_detail.input_descriptions[0].kinesis_streams_input_description.role_arn #=> String
# resp.application_detail.input_descriptions[0].kinesis_firehose_input_description.resource_arn #=> String
# resp.application_detail.input_descriptions[0].kinesis_firehose_input_description.role_arn #=> String
# resp.application_detail.input_descriptions[0].input_schema.record_format.record_format_type #=> String, one of "JSON", "CSV"
@@ -912,35 +1012,53 @@
#
#
#
# [1]: http://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html
#
- # @option params [required, String] :resource_arn
+ # @option params [String] :resource_arn
# Amazon Resource Name (ARN) of the streaming source.
#
- # @option params [required, String] :role_arn
+ # @option params [String] :role_arn
# ARN of the IAM role that Amazon Kinesis Analytics can assume to access
# the stream on your behalf.
#
- # @option params [required, Types::InputStartingPositionConfiguration] :input_starting_position_configuration
+ # @option params [Types::InputStartingPositionConfiguration] :input_starting_position_configuration
# Point at which you want Amazon Kinesis Analytics to start reading
# records from the specified streaming source discovery purposes.
#
+ # @option params [Types::S3Configuration] :s3_configuration
+ #
+ # @option params [Types::InputProcessingConfiguration] :input_processing_configuration
+ # The InputProcessingConfiguration to use to preprocess the records
+ # before discovering the schema of the records.
+ #
# @return [Types::DiscoverInputSchemaResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::DiscoverInputSchemaResponse#input_schema #input_schema} => Types::SourceSchema
# * {Types::DiscoverInputSchemaResponse#parsed_input_records #parsed_input_records} => Array<Array<String>>
+ # * {Types::DiscoverInputSchemaResponse#processed_input_records #processed_input_records} => Array<String>
# * {Types::DiscoverInputSchemaResponse#raw_input_records #raw_input_records} => Array<String>
#
# @example Request syntax with placeholder values
#
# resp = client.discover_input_schema({
- # resource_arn: "ResourceARN", # required
- # role_arn: "RoleARN", # required
- # input_starting_position_configuration: { # required
+ # resource_arn: "ResourceARN",
+ # role_arn: "RoleARN",
+ # input_starting_position_configuration: {
# input_starting_position: "NOW", # accepts NOW, TRIM_HORIZON, LAST_STOPPED_POINT
# },
+ # s3_configuration: {
+ # role_arn: "RoleARN", # required
+ # bucket_arn: "BucketARN", # required
+ # file_key: "FileKey", # required
+ # },
+ # input_processing_configuration: {
+ # input_lambda_processor: { # required
+ # resource_arn: "ResourceARN", # required
+ # role_arn: "RoleARN", # required
+ # },
+ # },
# })
#
# @example Response structure
#
# resp.input_schema.record_format.record_format_type #=> String, one of "JSON", "CSV"
@@ -953,10 +1071,12 @@
# resp.input_schema.record_columns[0].mapping #=> String
# resp.input_schema.record_columns[0].sql_type #=> String
# resp.parsed_input_records #=> Array
# resp.parsed_input_records[0] #=> Array
# resp.parsed_input_records[0][0] #=> String
+ # resp.processed_input_records #=> Array
+ # resp.processed_input_records[0] #=> String
# resp.raw_input_records #=> Array
# resp.raw_input_records[0] #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalytics-2015-08-14/DiscoverInputSchema AWS API Documentation
#
@@ -1131,10 +1251,16 @@
# application_update: { # required
# input_updates: [
# {
# input_id: "Id", # required
# name_prefix_update: "InAppStreamName",
+ # input_processing_configuration_update: {
+ # input_lambda_processor_update: { # required
+ # resource_arn_update: "ResourceARN",
+ # role_arn_update: "RoleARN",
+ # },
+ # },
# kinesis_streams_input_update: {
# resource_arn_update: "ResourceARN",
# role_arn_update: "RoleARN",
# },
# kinesis_firehose_input_update: {
@@ -1249,10 +1375,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-kinesisanalytics'
- context[:gem_version] = '1.0.0'
+ context[:gem_version] = '1.1.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated