Class: AWSCDK::KinesisFirehose::CfnDeliveryStream::DeserializerProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_firehose/cfn_delivery_stream.rb

Overview

The deserializer you want Kinesis Data Firehose to use for converting the input data from JSON.

Kinesis Data Firehose then serializes the data to its final format using the Serializer . Kinesis Data Firehose supports two types of deserializers: the Apache Hive JSON SerDe and the OpenX JSON SerDe .

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(hive_json_ser_de: nil, open_x_json_ser_de: nil) ⇒ DeserializerProperty

Returns a new instance of DeserializerProperty.

Parameters:



1985
1986
1987
1988
1989
1990
 
# File 'kinesis_firehose/cfn_delivery_stream.rb', line 1985

def initialize(hive_json_ser_de: nil, open_x_json_ser_de: nil)
  @hive_json_ser_de = hive_json_ser_de.is_a?(Hash) ? ::AWSCDK::KinesisFirehose::CfnDeliveryStream::HiveJsonSerDeProperty.new(**hive_json_ser_de.transform_keys(&:to_sym)) : hive_json_ser_de
  Jsii::Type.check_type(@hive_json_ser_de, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzZmlyZWhvc2UuQ2ZuRGVsaXZlcnlTdHJlYW0uSGl2ZUpzb25TZXJEZVByb3BlcnR5In1dfX0=")), "hiveJsonSerDe") unless @hive_json_ser_de.nil?
  @open_x_json_ser_de = open_x_json_ser_de.is_a?(Hash) ? ::AWSCDK::KinesisFirehose::CfnDeliveryStream::OpenXJsonSerDeProperty.new(**open_x_json_ser_de.transform_keys(&:to_sym)) : open_x_json_ser_de
  Jsii::Type.check_type(@open_x_json_ser_de, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19raW5lc2lzZmlyZWhvc2UuQ2ZuRGVsaXZlcnlTdHJlYW0uT3BlblhKc29uU2VyRGVQcm9wZXJ0eSJ9XX19")), "openXJsonSerDe") unless @open_x_json_ser_de.nil?
end

Instance Attribute Details

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

The native Hive / HCatalog JsonSerDe.

Used by Firehose for deserializing data, which means converting it from the JSON format in preparation for serializing it to the Parquet or ORC format. This is one of two deserializers you can choose, depending on which one offers the functionality you need. The other option is the OpenX SerDe.

Returns:

See Also:



1998
1999
2000
 
# File 'kinesis_firehose/cfn_delivery_stream.rb', line 1998

def hive_json_ser_de
  @hive_json_ser_de
end

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

The OpenX SerDe.

Used by Firehose for deserializing data, which means converting it from the JSON format in preparation for serializing it to the Parquet or ORC format. This is one of two deserializers you can choose, depending on which one offers the functionality you need. The other option is the native Hive / HCatalog JsonSerDe.

Returns:

See Also:



2005
2006
2007
 
# File 'kinesis_firehose/cfn_delivery_stream.rb', line 2005

def open_x_json_ser_de
  @open_x_json_ser_de
end

Class Method Details

.jsii_properties ⇒ Object 



2007
2008
2009
2010
2011
2012
 
# File 'kinesis_firehose/cfn_delivery_stream.rb', line 2007

def self.jsii_properties
  {
    :hive_json_ser_de => "hiveJsonSerDe",
    :open_x_json_ser_de => "openXJsonSerDe",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



2014
2015
2016
2017
2018
2019
2020
2021
 
# File 'kinesis_firehose/cfn_delivery_stream.rb', line 2014

def to_jsii
  result = {}
  result.merge!({
    "hiveJsonSerDe" => @hive_json_ser_de,
    "openXJsonSerDe" => @open_x_json_ser_de,
  })
  result.compact
end