Skip to main content

parse_chunk

Function parse_chunk 

Source
pub(super) fn parse_chunk(
    chunk: &mut [u8],
    chunk_logical: u64,
    record_size: usize,
) -> Vec<ParsedBatch>
Expand description

Fan a chunk’s record sub-ranges across rayon workers. The returned batches are in sub-range order, so appending them sequentially yields the same EntryId assignment as a fully sequential parse.