Class: AWSCDK::KinesisAnalytics::CfnApplicationV2::RecordColumnProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_analytics/cfn_application_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.

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.



2070
2071
2072
2073
2074
2075
2076
2077
# File 'kinesis_analytics/cfn_application_v2.rb', line 2070

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

#mappingString? (readonly)

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



2093
2094
2095
# File 'kinesis_analytics/cfn_application_v2.rb', line 2093

def mapping
  @mapping
end

#nameString (readonly)

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



2083
2084
2085
# File 'kinesis_analytics/cfn_application_v2.rb', line 2083

def name
  @name
end

#sql_typeString (readonly)

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



2088
2089
2090
# File 'kinesis_analytics/cfn_application_v2.rb', line 2088

def sql_type
  @sql_type
end

Class Method Details

.jsii_propertiesObject



2095
2096
2097
2098
2099
2100
2101
# File 'kinesis_analytics/cfn_application_v2.rb', line 2095

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

Instance Method Details

#to_jsiiObject



2103
2104
2105
2106
2107
2108
2109
2110
2111
# File 'kinesis_analytics/cfn_application_v2.rb', line 2103

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