Struct SpillRunReader 

pub struct SpillRunReader<T, K> { /* private fields */ }

Reader for one spill run file.

Implementations

impl<T, K> SpillRunReader<T, K>

pub fn open<DK, DR>( path: PathBuf, decode_key: DK, decode_row: DR, ) -> Result<Self>

where DK: Fn(&[u8]) -> Result<K> + 'static, DR: Fn(u64, &[u8]) -> Result<T> + 'static,

Open a spill run and configure decoders for key and row payloads.

pub fn next_entry(&mut self) -> Result<Option<SpillEntry<T, K>>>

Read the next spill entry, or None at end of run.

Trait Implementations

impl<T, K> Drop for SpillRunReader<T, K>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.