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