Function iceberg_rust::arrow::write::write_parquet_partitioned

source ยท 
pub async fn write_parquet_partitioned(
    metadata: &TableMetadata,
    batches: impl Stream<Item = Result<RecordBatch, ArrowError>> + Send,
    object_store: Arc<dyn ObjectStore>,
    branch: Option<&str>,
) -> Result<Vec<DataFile>, ArrowError>
Expand description

Partitions arrow record batches and writes them to parquet files. Does not perform any operation on an iceberg table.