pub trait Operator: Send + Sync {
// Required methods
fn next(&mut self) -> OperatorResult;
fn reset(&mut self);
fn name(&self) -> &'static str;
fn into_any(self: Box<Self>) -> Box<dyn Any + Send>;
}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§
Sourcefn next(&mut self) -> OperatorResult
fn next(&mut self) -> OperatorResult
Pulls the next batch of data. Returns None when exhausted.
§Errors
Returns Err if the operator encounters a runtime error.