You are viewing documentation for version 3 of the AWS SDK for Ruby. Version 2 documentation can be found here.

Class: Aws::KinesisAnalytics::Types::AddApplicationInputRequest

Inherits:
Struct
  • Object
show all
Defined in:
gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb

Overview

Note:

When making an API call, you may pass AddApplicationInputRequest data as a hash:

{
  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: {
      resource_arn: "ResourceARN", # required
      role_arn: "RoleARN", # required
    },
    input_parallelism: {
      count: 1,
    },
    input_schema: { # required
      record_format: { # required
        record_format_type: "JSON", # required, accepts JSON, CSV
        mapping_parameters: {
          json_mapping_parameters: {
            record_row_path: "RecordRowPath", # required
          },
          csv_mapping_parameters: {
            record_row_delimiter: "RecordRowDelimiter", # required
            record_column_delimiter: "RecordColumnDelimiter", # required
          },
        },
      },
      record_encoding: "RecordEncoding",
      record_columns: [ # required
        {
          name: "RecordColumnName", # required
          mapping: "RecordColumnMapping",
          sql_type: "RecordColumnSqlType", # required
        },
      ],
    },
  },
}

Instance Attribute Summary collapse

Instance Attribute Details

#application_nameString

Name of your existing Amazon Kinesis Analytics application to which you want to add the streaming source.

Returns:

  • (String)


170
171
172
173
174
175
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 170

class AddApplicationInputRequest < Struct.new(
  :application_name,
  :current_application_version_id,
  :input)
  include Aws::Structure
end

#current_application_version_idInteger

Current version of your Amazon Kinesis Analytics application. You can use the DescribeApplication operation to find the current application version.

Returns:

  • (Integer)


170
171
172
173
174
175
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 170

class AddApplicationInputRequest < Struct.new(
  :application_name,
  :current_application_version_id,
  :input)
  include Aws::Structure
end

#inputTypes::Input

The Input to add.

Returns:



170
171
172
173
174
175
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 170

class AddApplicationInputRequest < Struct.new(
  :application_name,
  :current_application_version_id,
  :input)
  include Aws::Structure
end