Skip to main content

slice_batch_by_vnode

Function slice_batch_by_vnode 

Source
pub fn slice_batch_by_vnode(
    batch: &RecordBatch,
    row_vnodes: &[u32],
    target: u32,
) -> Option<RecordBatch>
Expand description

The sub-batch of batch whose row_vnodes[i] == target, or None if no row maps to target.

§Panics

Panics if the take or rebuild fails — only on an internal-invariant violation (the indices are derived from batch itself).