Class: AWSCDK::KinesisAnalytics::CfnApplicationReferenceDataSourceV2::RecordColumnProperty

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 mapping of each data element in the streaming source to the corresponding column in the in-application stream.

Also used to describe the format of the reference data source.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name:, sql_type:, mapping: nil) ⇒ RecordColumnProperty

Returns a new instance of RecordColumnProperty.

Parameters:

  • name (String) —

    The name of the column that is created in the in-application input stream or reference table.

  • sql_type (String) —

    The type of column created in the in-application input stream or reference table.

  • mapping (String, nil) (defaults to: nil) —

    A reference to the data element in the streaming input or the reference data source.



648
649
650
651
652
653
654
655
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 648

def initialize(name:, sql_type:, mapping: nil)
  @name = name
  Jsii::Type.check_type(@name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "name")
  @sql_type = sql_type
  Jsii::Type.check_type(@sql_type, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "sqlType")
  @mapping = mapping
  Jsii::Type.check_type(@mapping, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "mapping") unless @mapping.nil?
end

Instance Attribute Details

#mapping ⇒ String? (readonly)

A reference to the data element in the streaming input or the reference data source.

Returns:

  • (String, nil)

See Also:



671
672
673
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 671

def mapping
  @mapping
end

#name ⇒ String (readonly)

The name of the column that is created in the in-application input stream or reference table.

Returns:

  • (String)

See Also:



661
662
663
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 661

def name
  @name
end

#sql_type ⇒ String (readonly)

The type of column created in the in-application input stream or reference table.

Returns:

  • (String)

See Also:



666
667
668
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 666

def sql_type
  @sql_type
end

Class Method Details

.jsii_properties ⇒ Object 



673
674
675
676
677
678
679
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 673

def self.jsii_properties
  {
    :name => "name",
    :sql_type => "sqlType",
    :mapping => "mapping",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



681
682
683
684
685
686
687
688
689
 
# File 'kinesis_analytics/cfn_application_reference_data_source_v2.rb', line 681

def to_jsii
  result = {}
  result.merge!({
    "name" => @name,
    "sqlType" => @sql_type,
    "mapping" => @mapping,
  })
  result.compact
end