class Amazonite::Kinesis::S3TablesDestinationConfiguration

Overview

The configuration for delivery to streaming tables on Apache Iceberg. Used in CreateChannel.

Included Modules

Defined in:

kinesis/s3_tables_destination_configuration.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration, s3_tables_configuration_list : Array(S3TablesConfiguration), data_freshness_in_seconds : Int32 | Nil = nil) #

[View source]
def self.new(pull : JSON::PullParser) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def data_freshness_in_seconds : Int32 | Nil #

The maximum age, in seconds, of undelivered data. Valid range is 300 to 900 seconds (5 to 15 minutes). The default value is 300 seconds.


[View source]
def data_freshness_in_seconds=(data_freshness_in_seconds : Int32 | Nil) #

The maximum age, in seconds, of undelivered data. Valid range is 300 to 900 seconds (5 to 15 minutes). The default value is 300 seconds.


[View source]
def dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration #

The dead-letter queue configuration for records that cannot be delivered. Required for streaming table destinations.


[View source]
def dead_letter_queue_s3_configuration=(dead_letter_queue_s3_configuration : DeadLetterQueueS3Configuration) #

The dead-letter queue configuration for records that cannot be delivered. Required for streaming table destinations.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def s3_tables_configuration_list : Array(S3TablesConfiguration) #

The list of streaming table configurations. Currently, one table is supported per channel.


[View source]
def s3_tables_configuration_list=(s3_tables_configuration_list : Array(S3TablesConfiguration)) #

The list of streaming table configurations. Currently, one table is supported per channel.


[View source]
def validate! : Nil #

[View source]