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

Class: Aws::KinesisAnalyticsV2::Types::ReferenceDataSource

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

Overview

Note:

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

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

For a SQL-based Kinesis Data Analytics application, describes the reference data source by providing the source information (Amazon S3 bucket name and object key name), the resulting in-application table name that is created, and the necessary schema to map the data elements in the Amazon S3 object to the in-application table.

Returned by:

See Also:

Instance Attribute Summary collapse

Instance Attribute Details

#reference_schema ⇒ Types::SourceSchema

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

Returns:

  • (Types::SourceSchema) —

    Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

#s3_reference_data_source ⇒ Types::S3ReferenceDataSource

Identifies the S3 bucket and object that contains the reference data. A Kinesis Data Analytics application loads reference data only once. If the data changes, you call the UpdateApplication operation to trigger reloading of data into your application.

Returns:

#table_name ⇒ String

The name of the in-application table to create.

Returns:

  • (String) —

    The name of the in-application table to create.