Class: AWSCDK::KinesisAnalytics::CfnApplicationReferenceDataSourceV2::ReferenceSchemaProperty

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

Overview

For a SQL-based Kinesis Data Analytics application, 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.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(record_columns:, record_format:, record_encoding: nil) ⇒ ReferenceSchemaProperty

Returns a new instance of ReferenceSchemaProperty.

Parameters:



799
800
801
802
803
804
805
806
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 799

def initialize(record_columns:, record_format:, record_encoding: nil)
  @record_columns = record_columns
  Jsii::Type.check_type(@record_columns, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImNvbGxlY3Rpb24iOnsiZWxlbWVudHR5cGUiOnsidW5pb24iOnsidHlwZXMiOlt7ImZxbiI6ImF3cy1jZGstbGliLklSZXNvbHZhYmxlIn0seyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfa2luZXNpc2FuYWx5dGljcy5DZm5BcHBsaWNhdGlvblJlZmVyZW5jZURhdGFTb3VyY2VWMi5SZWNvcmRDb2x1bW5Qcm9wZXJ0eSJ9XX19LCJraW5kIjoiYXJyYXkifX1dfX0=")), "recordColumns")
  @record_format = record_format.is_a?(Hash) ? ::AWSCDK::KinesisAnalytics::CfnApplicationReferenceDataSourceV2::RecordFormatProperty.new(**record_format.transform_keys(&:to_sym)) : record_format
  Jsii::Type.check_type(@record_format, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzYW5hbHl0aWNzLkNmbkFwcGxpY2F0aW9uUmVmZXJlbmNlRGF0YVNvdXJjZVYyLlJlY29yZEZvcm1hdFByb3BlcnR5In1dfX0=")), "recordFormat")
  @record_encoding = record_encoding
  Jsii::Type.check_type(@record_encoding, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "recordEncoding") unless @record_encoding.nil?
end

Instance Attribute Details

#record_columns ⇒ AWSCDK::IResolvable, Array<AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplicationReferenceDataSourceV2::RecordColumnProperty> (readonly)

A list of RecordColumn objects.

Returns:

See Also:



812
813
814
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 812

def record_columns
  @record_columns
end

#record_encoding ⇒ String? (readonly)

Specifies the encoding of the records in the streaming source.

For example, UTF-8.

Returns:

  • (String, nil)

See Also:



824
825
826
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 824

def record_encoding
  @record_encoding
end

#record_format ⇒ AWSCDK::IResolvable, AWSCDK::KinesisAnalytics::CfnApplicationReferenceDataSourceV2::RecordFormatProperty (readonly)

Specifies the format of the records on the streaming source.

Returns:

See Also:



817
818
819
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 817

def record_format
  @record_format
end

Class Method Details

.jsii_properties ⇒ Object 



826
827
828
829
830
831
832
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 826

def self.jsii_properties
  {
    :record_columns => "recordColumns",
    :record_format => "recordFormat",
    :record_encoding => "recordEncoding",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



834
835
836
837
838
839
840
841
842
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 834

def to_jsii
  result = {}
  result.merge!({
    "recordColumns" => @record_columns,
    "recordFormat" => @record_format,
    "recordEncoding" => @record_encoding,
  })
  result.compact
end