Class: Aws::KinesisAnalytics::Types::InputUpdate

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

{
  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,
  },
}

Describes updates to a specific input configuration (identified by the InputId of an application).

Constant Summary collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#input_idString

Input ID of the application input to be updated.

Returns:

  • (String)


2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#input_parallelism_updateTypes::InputParallelismUpdate

Describes the parallelism updates (the number in-application streams Amazon Kinesis Analytics creates for the specific streaming source).



2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#input_processing_configuration_updateTypes::InputProcessingConfigurationUpdate

Describes updates for an input processing configuration.



2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#input_schema_updateTypes::InputSchemaUpdate

Describes the data format on the streaming source, and how record elements on the streaming source map to columns of the in-application stream that is created.



2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#kinesis_firehose_input_updateTypes::KinesisFirehoseInputUpdate

If an Amazon Kinesis Firehose delivery stream is the streaming source to be updated, provides an updated stream ARN and IAM role ARN.



2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#kinesis_streams_input_updateTypes::KinesisStreamsInputUpdate

If an Amazon Kinesis stream is the streaming source to be updated, provides an updated stream Amazon Resource Name (ARN) and IAM role ARN.



2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end

#name_prefix_updateString

Name prefix for in-application streams that Amazon Kinesis Analytics creates for the specific streaming source.

Returns:

  • (String)


2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
# File 'gems/aws-sdk-kinesisanalytics/lib/aws-sdk-kinesisanalytics/types.rb', line 2054

class InputUpdate < Struct.new(
  :input_id,
  :name_prefix_update,
  :input_processing_configuration_update,
  :kinesis_streams_input_update,
  :kinesis_firehose_input_update,
  :input_schema_update,
  :input_parallelism_update)
  SENSITIVE = []
  include Aws::Structure
end