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

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

Inherits:
Struct
  • Object
show all
Defined in:
(unknown)

Overview

Note:

When passing AddApplicationInputRequest as input to an Aws::Client method, you can use a vanilla 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
        },
      ],
    },
  },
}

See Also:

Instance Attribute Summary collapse

Instance Attribute Details

#application_name ⇒ String

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

Returns:

  • (String) —

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

#current_application_version_id ⇒ Integer

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

Returns:

  • (Integer) —

    Current version of your Amazon Kinesis Analytics application.

#input ⇒ Types::Input

The Input to add.

Returns: