Trait WindowExecutor 

pub trait WindowExecutor: Send {
    // Required methods
    fn consume(&mut self, batch: Batch) -> ExecResult<()>;
    fn finish(&mut self) -> ExecResult<SpillBuffer>;
}

Byte-bounded window operator. Input sorting, random-access partitions, and output rows use disk-backed buffers; only fixed-size batches are decoded at the Volcano boundary.

Required Methods

fn consume(&mut self, batch: Batch) -> ExecResult<()>

Consume one child batch without materializing the complete input in the physical operator.

fn finish(&mut self) -> ExecResult<SpillBuffer>

Finalize window columns into a byte-bounded, disk-backed output stream.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors