Struct S3IcebergDirectTarget 

#[non_exhaustive]
pub struct S3IcebergDirectTarget {
    pub name: String,
    pub inputs: Vec<String>,
    pub partition_keys: Option<Vec<Vec<String>>>,
    pub path: String,
    pub format: TargetFormat,
    pub additional_options: Option<HashMap<String, String>>,
    pub schema_change_policy: Option<DirectSchemaChangePolicy>,
    pub auto_data_quality: Option<AutoDataQuality>,
    pub compression: IcebergTargetCompressionType,
    pub number_target_partitions: Option<String>,
    pub output_schemas: Option<Vec<GlueSchema>>,
}

Specifies a target that writes to an Iceberg data source in Amazon S3.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

name: String

Specifies the unique identifier for the Iceberg target node in your data pipeline.

inputs: Vec<String>

Defines the single input source that provides data to this Iceberg target.

partition_keys: Option<Vec<Vec<String>>>

Specifies the columns used to partition the Iceberg table data in S3.

path: String

Defines the S3 location where the Iceberg table data will be stored.

format: TargetFormat

Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).

additional_options: Option<HashMap<String, String>>

Provides additional configuration options for customizing the Iceberg table behavior.

schema_change_policy: Option<DirectSchemaChangePolicy>

Defines how schema changes are handled when writing data to the Iceberg table.

auto_data_quality: Option<AutoDataQuality>

Specifies configuration options for automatic data quality evaluation in Glue jobs. This structure enables automated data quality checks and monitoring during ETL operations, helping to ensure data integrity and reliability without manual intervention.

compression: IcebergTargetCompressionType

Specifies the compression codec used for Iceberg table files in S3.

number_target_partitions: Option<String>

Sets the number of target partitions for distributing Iceberg table files across S3.

output_schemas: Option<Vec<GlueSchema>>

Specifies the data schema for the S3 Iceberg direct target.

Implementations

impl S3IcebergDirectTarget

pub fn name(&self) -> &str

Specifies the unique identifier for the Iceberg target node in your data pipeline.

pub fn inputs(&self) -> &[String]

Defines the single input source that provides data to this Iceberg target.

pub fn partition_keys(&self) -> &[Vec<String>]

Specifies the columns used to partition the Iceberg table data in S3.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .partition_keys.is_none().

pub fn path(&self) -> &str

Defines the S3 location where the Iceberg table data will be stored.

pub fn format(&self) -> &TargetFormat

Specifies the file format used for storing Iceberg table data (e.g., Parquet, ORC).

pub fn additional_options(&self) -> Option<&HashMap<String, String>>

Provides additional configuration options for customizing the Iceberg table behavior.

pub fn schema_change_policy(&self) -> Option<&DirectSchemaChangePolicy>

Defines how schema changes are handled when writing data to the Iceberg table.

pub fn auto_data_quality(&self) -> Option<&AutoDataQuality>

Specifies configuration options for automatic data quality evaluation in Glue jobs. This structure enables automated data quality checks and monitoring during ETL operations, helping to ensure data integrity and reliability without manual intervention.

pub fn compression(&self) -> &IcebergTargetCompressionType

Specifies the compression codec used for Iceberg table files in S3.

pub fn number_target_partitions(&self) -> Option<&str>

Sets the number of target partitions for distributing Iceberg table files across S3.

pub fn output_schemas(&self) -> &[GlueSchema]

Specifies the data schema for the S3 Iceberg direct target.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .output_schemas.is_none().

impl S3IcebergDirectTarget

pub fn builder() -> S3IcebergDirectTargetBuilder

Creates a new builder-style object to manufacture S3IcebergDirectTarget.

Trait Implementations

impl Clone for S3IcebergDirectTarget

fn clone(&self) -> S3IcebergDirectTarget

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for S3IcebergDirectTarget

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for S3IcebergDirectTarget

fn eq(&self, other: &S3IcebergDirectTarget) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for S3IcebergDirectTarget