Function iceberg_rust::arrow::partition::partition_record_batches

source ยท 
pub async fn partition_record_batches(
    record_batches: impl Stream<Item = Result<RecordBatch, ArrowError>> + Send,
    partition_spec: &PartitionSpec,
    schema: &Schema,
) -> Result<Vec<(Vec<Value>, impl Stream<Item = Result<RecordBatch, ArrowError>> + Send)>, ArrowError>
Expand description

Partition stream of record batches according to partition spec