split_into_batches

Function split_into_batches 

Source
pub fn split_into_batches(geometry: &[u8]) -> Option<Vec<ReplayBatch>>
Expand description

Split a cached geometry blob (the inner section framing cached_geometry_slice returns) back into per-original-batch chunks.

Returns None when the blob carries no recoverable batch boundary — a short/corrupt/foreign blob, or one written as a single row group (a one-shot serialize_to_parquet cache entry, or a stream that emitted one batch). In the single-row-group case re-encoding would only reproduce the bytes the caller already holds, so falling back is both cheaper and byte-equivalent.