Struct IndexedSpill 

pub struct IndexedSpill { /* private fields */ }

Disk-only physical-row store with constant-memory positional lookup.

Each row retains the exact physical layout described by schema and is encoded with the same positional tagged representation as SpillBuffer. Record offsets live in a second temporary file, so even a partition with billions of rows does not create an in-memory offset table. A single decoded physical row is the only input-sized allocation retained by Self::get. Both files are unlinked by NamedTempFile on drop.

Implementations

impl IndexedSpill

pub fn new(input_schema: RowSchema) -> ExecResult<Self>

pub fn len(&self) -> u64

pub fn is_empty(&self) -> bool

pub fn encoded_bytes(&self) -> u64

pub fn row_schema(&self) -> &RowSchema

pub fn push(&mut self, row: &PhysicalRow) -> ExecResult<()>

Append one indivisible row. Failed writes roll both files back to their original lengths, so callers never observe a partial index entry.

pub fn get(&mut self, index: u64) -> ExecResult<PhysicalRow>

Decode the row at index without loading any other row or index entry.