Function row_group_iter

pub fn row_group_iter<A: AsRef<dyn Array> + 'static + Send + Sync>(
    chunk: RecordBatchT<A>,
    encodings: Vec<Vec<Encoding>>,
    fields: Vec<ParquetType>,
    options: WriteOptions,
) -> RowGroupIterColumns<'static, PolarsError>

Maps a RecordBatchT and parquet-specific options to an RowGroupIterColumns used to write to parquet

Panics

Iff

• encodings.len() != fields.len() or
• encodings.len() != chunk.arrays().len()