class Amazonite::Kinesis::S3TablesConfiguration

Overview

Specifies a destination streaming table on Apache Iceberg.

Included Modules

Defined in:

kinesis/s3_tables_configuration.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(table_bucket_arn : String, namespace : String, table_name : String, compression_type : S3TablesCompressionType, partition_spec : PartitionSpec | Nil = nil) #

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

[View source]
def self.new(*, __pull_for_json_serializable 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 compression_type : S3TablesCompressionType #

The compression applied to Parquet data files. Valid values:

  • NONE - No compression.

  • ZSTD - Zstandard compression.

  • SNAPPY - Snappy compression.


[View source]
def compression_type=(compression_type : S3TablesCompressionType) #

The compression applied to Parquet data files. Valid values:

  • NONE - No compression.

  • ZSTD - Zstandard compression.

  • SNAPPY - Snappy compression.


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

See Object#hash(hasher)


def namespace : String #

The namespace (database) of the destination table.


[View source]
def namespace=(namespace : String) #

The namespace (database) of the destination table.


[View source]
def partition_spec : PartitionSpec | Nil #

The partitioning specification for the destination table.


[View source]
def partition_spec=(partition_spec : PartitionSpec | Nil) #

The partitioning specification for the destination table.


[View source]
def table_bucket_arn : String #

The Amazon Resource Name (ARN) of the Amazon S3 table bucket.


[View source]
def table_bucket_arn=(table_bucket_arn : String) #

The Amazon Resource Name (ARN) of the Amazon S3 table bucket.


[View source]
def table_name : String #

The name of the destination table. Amazon Kinesis Data Streams creates this table in the specified table bucket.


[View source]
def table_name=(table_name : String) #

The name of the destination table. Amazon Kinesis Data Streams creates this table in the specified table bucket.


[View source]
def validate! : Nil #

[View source]