Skip to main content

Storage

kyu_executor::context

Trait Storage 

Source 
pub trait Storage: Debug {
    // Required method
    fn scan_table(
        &self,
        table_id: TableId,
    ) -> Box<dyn Iterator<Item = DataChunk> + '_>;
}
Expand description

Abstraction over table storage backends.

kyu-executor depends only on this trait. Concrete implementations (MockStorage for tests, NodeGroupStorage for real storage) live in their respective crates.

Required Methods§

Source

fn scan_table( &self, table_id: TableId, ) -> Box<dyn Iterator<Item = DataChunk> + '_>

Iterate DataChunk batches for a table. Returns empty iterator if table missing.

Implementors§