Struct AsyncSpillFile 

pub struct AsyncSpillFile { /* private fields */ }

Async handle for a single spill file.

AsyncSpillFile manages a temporary file used for spilling operator state to disk using tokio’s async I/O primitives for non-blocking operations.

Implementations

impl AsyncSpillFile

pub async fn new(path: PathBuf) -> Result<Self>

Creates a new async spill file at the given path.

Errors

Returns an error if the file cannot be created.

pub fn path(&self) -> &Path

Returns the path to this spill file.

pub fn bytes_written(&self) -> u64

Returns the number of bytes written to this file.

pub async fn write_all(&mut self, data: &[u8]) -> Result<()>

Writes raw bytes to the file asynchronously.

Errors

Returns an error if the write fails.

pub async fn write_u64_le(&mut self, value: u64) -> Result<()>

Writes a u64 in little-endian format.

Errors

Returns an error if the write fails.

pub async fn write_i64_le(&mut self, value: i64) -> Result<()>

Writes an i64 in little-endian format.

Errors

Returns an error if the write fails.

pub async fn write_bytes(&mut self, data: &[u8]) -> Result<()>

Writes a length-prefixed byte slice.

Format: [length: u64][data: bytes]

Errors

Returns an error if the write fails.

pub async fn finish_write(&mut self) -> Result<()>

Finishes writing and flushes buffers.

After this call, the file is ready for reading.

Errors

Returns an error if the flush fails.

pub fn is_writable(&self) -> bool

Returns whether this file is still in write mode.

pub async fn reader(&self) -> Result<AsyncSpillFileReader>

Creates an async reader for this file.

Can be called multiple times to create multiple readers.

Errors

Returns an error if the file cannot be opened for reading.

pub async fn delete(self) -> Result<()>

Deletes this spill file.

Consumes the AsyncSpillFile handle.

Errors

Returns an error if the file cannot be deleted.

Trait Implementations

impl Debug for AsyncSpillFile

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.