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
- Struct
- Aws::KinesisAnalyticsV2::Types::SqlApplicationConfiguration
- Defined in:
- (unknown)
Overview
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:
Instance Attribute Summary collapse
-
#inputs ⇒ 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.
-
#reference_data_sources ⇒ Array<Types::ReferenceDataSource>
The array of ReferenceDataSource objects describing the reference data sources used by the application.
Instance Attribute Details
#inputs ⇒ 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.
#reference_data_sources ⇒ Array<Types::ReferenceDataSource>
The array of ReferenceDataSource objects describing the reference data sources used by the application.