mz_sql::plan::statement::ddl

Function iceberg_sink_builder

Source 
fn iceberg_sink_builder(
    scx: &StatementContext<'_>,
    catalog_connection: ResolvedItemName,
    aws_connection: ResolvedItemName,
    options: Vec<IcebergSinkConfigOption<Aug>>,
    relation_key_indices: Option<Vec<usize>>,
    key_desc_and_indices: Option<(RelationDesc, Vec<usize>)>,
) -> Result<StorageSinkConnection<ReferencedConnection>, PlanError>