Class: AWSCDK::KinesisAnalytics::CfnApplication::RecordFormatProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analytics/cfn_application.rb

Overview

Describes the record format and relevant mapping information that should be applied to schematize the records on the stream.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(record_format_type:, mapping_parameters: nil) ⇒ RecordFormatProperty

Returns a new instance of RecordFormatProperty.

Parameters:

  • record_format_type (String)

    The type of record format.

  • mapping_parameters (AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplication::MappingParametersProperty, nil) (defaults to: nil)

    When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.



1091
1092
1093
1094
1095
1096
# File 'kinesis_analytics/cfn_application.rb', line 1091

def initialize(record_format_type:, mapping_parameters: nil)
  @record_format_type = record_format_type
  Jsii::Type.check_type(@record_format_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "recordFormatType")
  @mapping_parameters = mapping_parameters.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplication::MappingParametersProperty.new(**mapping_parameters.transform_keys(&:to_sym)) : mapping_parameters
  Jsii::Type.check_type(@mapping_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uLk1hcHBpbmdQYXJhbWV0ZXJzUHJvcGVydHkifV19fQ==")), "mappingParameters") unless @mapping_parameters.nil?
end

Instance Attribute Details

#mapping_parametersAWSCDK::IResolvable, ... (readonly)

When configuring application input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.



1107
1108
1109
# File 'kinesis_analytics/cfn_application.rb', line 1107

def mapping_parameters
  @mapping_parameters
end

#record_format_typeString (readonly)

The type of record format.



1102
1103
1104
# File 'kinesis_analytics/cfn_application.rb', line 1102

def record_format_type
  @record_format_type
end

Class Method Details

.jsii_propertiesObject



1109
1110
1111
1112
1113
1114
# File 'kinesis_analytics/cfn_application.rb', line 1109

def self.jsii_properties
  {
    :record_format_type => "recordFormatType",
    :mapping_parameters => "mappingParameters",
  }
end

Instance Method Details

#to_jsiiObject



1116
1117
1118
1119
1120
1121
1122
1123
# File 'kinesis_analytics/cfn_application.rb', line 1116

def to_jsii
  result = {}
  result.merge!({
    "recordFormatType" => @record_format_type,
    "mappingParameters" => @mapping_parameters,
  })
  result.compact
end