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.