Skip to main content

Operator

grafeo_core::execution::operators

Trait Operator 

Source 
pub trait Operator: Send + Sync {
    // Required methods
    fn next(&mut self) -> OperatorResult;
    fn reset(&mut self);
    fn name(&self) -> &'static str;
}
Expand description

The core trait for pull-based operators.

Call next() repeatedly until it returns None. Each call returns a batch of rows (a DataChunk) or an error.

Required Methods§

Source

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

Source

fn reset(&mut self)

Resets to initial state so you can iterate again.

Source

fn name(&self) -> &'static str

Returns a name for debugging/explain output.

Implementors§