Class: AWSCDK::KinesisAnalytics::CfnApplicationV2::MappingParametersProperty

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

Overview

When you configure a SQL-based Kinesis Data Analytics application's 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.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(csv_mapping_parameters: nil, json_mapping_parameters: nil) ⇒ MappingParametersProperty

Returns a new instance of MappingParametersProperty.

Parameters:



1796
1797
1798
1799
1800
1801
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1796

def initialize(csv_mapping_parameters: nil, json_mapping_parameters: nil)
  @csv_mapping_parameters = csv_mapping_parameters.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::CSVMappingParametersProperty.new(**csv_mapping_parameters.transform_keys(&:to_sym)) : csv_mapping_parameters
  Jsii::Type.check_type(@csv_mapping_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuQ1NWTWFwcGluZ1BhcmFtZXRlcnNQcm9wZXJ0eSJ9XX19")), "csvMappingParameters") unless @csv_mapping_parameters.nil?
  @json_mapping_parameters = json_mapping_parameters.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationV2::JSONMappingParametersProperty.new(**json_mapping_parameters.transform_keys(&:to_sym)) : json_mapping_parameters
  Jsii::Type.check_type(@json_mapping_parameters, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uVjIuSlNPTk1hcHBpbmdQYXJhbWV0ZXJzUHJvcGVydHkifV19fQ==")), "jsonMappingParameters") unless @json_mapping_parameters.nil?
end

Instance Attribute Details

#csv_mapping_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

Provides additional mapping information when the record format uses delimiters (for example, CSV).

Returns:

See Also:



1807
1808
1809
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1807

def csv_mapping_parameters
  @csv_mapping_parameters
end

#json_mapping_parameters ⇒ AWSCDK::IResolvable, ... (readonly)

Provides additional mapping information when JSON is the record format on the streaming source.

Returns:

See Also:



1812
1813
1814
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1812

def json_mapping_parameters
  @json_mapping_parameters
end

Class Method Details

.jsii_properties ⇒ Object 



1814
1815
1816
1817
1818
1819
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1814

def self.jsii_properties
  {
    :csv_mapping_parameters => "csvMappingParameters",
    :json_mapping_parameters => "jsonMappingParameters",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1821
1822
1823
1824
1825
1826
1827
1828
 
# File 'kinesis_analytics/cfn_application_v2.rb', line 1821

def to_jsii
  result = {}
  result.merge!({
    "csvMappingParameters" => @csv_mapping_parameters,
    "jsonMappingParameters" => @json_mapping_parameters,
  })
  result.compact
end