Struct GatherOperator 

pub struct GatherOperator {
    pub kind: GatherOperatorKind,
    pub runtime: Option<Arc<ExecutionRuntime>>,
    pub output_layout: Arc<SlotLayout>,
    pub config: OperatorConfig,
}

Gather operator.

Wraps GatherOperatorKind with the runtime context injected at open(). Lifecycle state is owned exclusively by the executor; operators never write it.

Fields

kind: GatherOperatorKind

runtime: Option<Arc<ExecutionRuntime>>

output_layout: Arc<SlotLayout>

config: OperatorConfig

Implementations

impl GatherOperator

pub fn new(kind: GatherOperatorKind, output_layout: Arc<SlotLayout>) -> Self

pub fn inject_context( &mut self, runtime: Option<&Arc<ExecutionRuntime>>, config: OperatorConfig, )

Inject the runtime and execution config (called once by the executor before this operator produces any data).

pub fn concatenate(output_layout: Arc<SlotLayout>) -> Self

pub fn merge_sort( sort_expressions: Vec<Expression>, sort_directions: Vec<SortDirection>, limit: Option<usize>, output_layout: Arc<SlotLayout>, ) -> Self

pub fn open( &mut self, children: &mut Vec<StreamingExecutor>, ) -> Result<(), QueryError>

pub fn next( &mut self, children: &mut [StreamingExecutor], ) -> Result<Option<DataChunk>, QueryError>

pub fn stop(&mut self) -> Result<(), QueryError>

pub fn close(&mut self) -> Result<(), QueryError>

Trait Implementations

impl Debug for GatherOperator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.