Class: Aws::KinesisAnalyticsV2::Types::AddApplicationInputRequest

Inherits:
Struct
  • Object
show all
Includes:
Structure
Defined in:
lib/aws-sdk-kinesisanalyticsv2/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
      },
    },
    kinesis_streams_input: {
      resource_arn: "ResourceARN", # required
    },
    kinesis_firehose_input: {
      resource_arn: "ResourceARN", # 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:

Constant Summary collapse

SENSITIVE = 
[]

Instance Attribute Summary collapse

Instance Attribute Details

#application_name ⇒ String

The name of your existing application to which you want to add the streaming source.

Returns:

  • (String) 


231
232
233
234
235
236
237
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 231

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

#current_application_version_id ⇒ Integer

The current version of your application. You must provide the `ApplicationVersionID` or the `ConditionalToken`.You can use the DescribeApplication operation to find the current application version.

Returns:

  • (Integer) 


231
232
233
234
235
236
237
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 231

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

#input ⇒ Types::Input

The Input to add.

Returns:



231
232
233
234
235
236
237
 
# File 'lib/aws-sdk-kinesisanalyticsv2/types.rb', line 231

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