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

Class: Aws::KinesisAnalytics::Types::ApplicationUpdate

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 ApplicationUpdate data as a hash:

{
  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: {
        resource_arn_update: "ResourceARN",
        role_arn_update: "RoleARN",
      },
      input_schema_update: {
        record_format_update: {
          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_update: "RecordEncoding",
        record_column_updates: [
          {
            name: "RecordColumnName", # required
            mapping: "RecordColumnMapping",
            sql_type: "RecordColumnSqlType", # required
          },
        ],
      },
      input_parallelism_update: {
        count_update: 1,
      },
    },
  ],
  application_code_update: "ApplicationCode",
  output_updates: [
    {
      output_id: "Id", # required
      name_update: "InAppStreamName",
      kinesis_streams_output_update: {
        resource_arn_update: "ResourceARN",
        role_arn_update: "RoleARN",
      },
      kinesis_firehose_output_update: {
        resource_arn_update: "ResourceARN",
        role_arn_update: "RoleARN",
      },
      destination_schema_update: {
        record_format_type: "JSON", # accepts JSON, CSV
      },
    },
  ],
  reference_data_source_updates: [
    {
      reference_id: "Id", # required
      table_name_update: "InAppTableName",
      s3_reference_data_source_update: {
        bucket_arn_update: "BucketARN",
        file_key_update: "FileKey",
        reference_role_arn_update: "RoleARN",
      },
      reference_schema_update: {
        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
          },
        ],
      },
    },
  ],
  cloud_watch_logging_option_updates: [
    {
      cloud_watch_logging_option_id: "Id", # required
      log_stream_arn_update: "LogStreamARN",
      role_arn_update: "RoleARN",
    },
  ],
}

Describes updates to apply to an existing Amazon Kinesis Analytics application.

Instance Attribute Summary collapse

Instance Attribute Details

#application_code_updateString

Describes application code updates.

Returns:

  • (String)


559
560
561
562
563
564
565
566
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 559

class ApplicationUpdate < Struct.new(
  :input_updates,
  :application_code_update,
  :output_updates,
  :reference_data_source_updates,
  :cloud_watch_logging_option_updates)
  include Aws::Structure
end

#cloud_watch_logging_option_updatesArray<Types::CloudWatchLoggingOptionUpdate>

Describes application CloudWatch logging option updates.



559
560
561
562
563
564
565
566
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 559

class ApplicationUpdate < Struct.new(
  :input_updates,
  :application_code_update,
  :output_updates,
  :reference_data_source_updates,
  :cloud_watch_logging_option_updates)
  include Aws::Structure
end

#input_updatesArray<Types::InputUpdate>

Describes application input configuration updates.

Returns:



559
560
561
562
563
564
565
566
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 559

class ApplicationUpdate < Struct.new(
  :input_updates,
  :application_code_update,
  :output_updates,
  :reference_data_source_updates,
  :cloud_watch_logging_option_updates)
  include Aws::Structure
end

#output_updatesArray<Types::OutputUpdate>

Describes application output configuration updates.

Returns:



559
560
561
562
563
564
565
566
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 559

class ApplicationUpdate < Struct.new(
  :input_updates,
  :application_code_update,
  :output_updates,
  :reference_data_source_updates,
  :cloud_watch_logging_option_updates)
  include Aws::Structure
end

#reference_data_source_updatesArray<Types::ReferenceDataSourceUpdate>

Describes application reference data source updates.



559
560
561
562
563
564
565
566
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 559

class ApplicationUpdate < Struct.new(
  :input_updates,
  :application_code_update,
  :output_updates,
  :reference_data_source_updates,
  :cloud_watch_logging_option_updates)
  include Aws::Structure
end