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

Class: Aws::KinesisAnalyticsV2::Types::SqlApplicationConfiguration

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

Overview

Note:

When passing SqlApplicationConfiguration as input to an Aws::Client method, you can use a vanilla Hash:

{
  inputs: [
    {
      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
          },
        ],
      },
    },
  ],
  outputs: [
    {
      name: "InAppStreamName", # required
      kinesis_streams_output: {
        resource_arn: "ResourceARN", # required
      },
      kinesis_firehose_output: {
        resource_arn: "ResourceARN", # required
      },
      lambda_output: {
        resource_arn: "ResourceARN", # required
      },
      destination_schema: { # required
        record_format_type: "JSON", # required, accepts JSON, CSV
      },
    },
  ],
  reference_data_sources: [
    {
      table_name: "InAppTableName", # required
      s3_reference_data_source: {
        bucket_arn: "BucketARN",
        file_key: "FileKey",
      },
      reference_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
          },
        ],
      },
    },
  ],
}

Describes the inputs, outputs, and reference data sources for a SQL-based Kinesis Data Analytics application.

Returned by:

See Also:

Instance Attribute Summary collapse

Instance Attribute Details

#inputs ⇒ Array<Types::Input>

The array of Input objects describing the input streams used by the application.

Returns:

  • (Array<Types::Input>) —

    The array of Input objects describing the input streams used by the application.

#outputs ⇒ Array<Types::Output>

The array of Output objects describing the destination streams used by the application.

Returns:

  • (Array<Types::Output>) —

    The array of Output objects describing the destination streams used by the application.

#reference_data_sources ⇒ Array<Types::ReferenceDataSource>

The array of ReferenceDataSource objects describing the reference data sources used by the application.

Returns: