Operator

ruvector_graph::executor::operators

Trait Operator 

Source 
pub trait Operator: Send + Sync {
    // Required methods
    fn execute(&mut self, input: Option<RowBatch>) -> Result<Option<RowBatch>>;
    fn name(&self) -> &str;

    // Provided method
    fn is_pipeline_breaker(&self) -> bool { ... }
}
Expand description

Base trait for all query operators

Required Methods§

Source

fn execute(&mut self, input: Option<RowBatch>) -> Result<Option<RowBatch>>

Execute operator and produce output batch

Source

fn name(&self) -> &str

Get operator name for debugging

Provided Methods§

Source

fn is_pipeline_breaker(&self) -> bool

Check if operator is pipeline breaker

Implementors§