pub trait Operator {
// Required methods
fn next_batch(&mut self) -> ExecutorResult<Option<ResultBatch>>;
fn columns(&self) -> &[String];
}Expand description
Operator in the execution pipeline.
Required Methods§
Sourcefn next_batch(&mut self) -> ExecutorResult<Option<ResultBatch>>
fn next_batch(&mut self) -> ExecutorResult<Option<ResultBatch>>
Get the next batch of results.