Struct UnwindOperator 

pub struct UnwindOperator { /* private fields */ }

Unwind operator that expands a list column into individual rows.

For each input row, if the list column contains N elements, this operator produces N output rows, each with one element from the list.

Implementations

impl UnwindOperator

pub fn new( child: Box<dyn Operator>, list_col_idx: usize, variable_name: String, output_schema: Vec<LogicalType>, ) -> Self

Creates a new unwind operator.

Arguments

• child - The input operator
• list_col_idx - The column index containing the list to unwind
• variable_name - The name of the new variable
• output_schema - The schema for output (should include the new column type)

pub fn variable_name(&self) -> &str

Returns the variable name for the unwound elements.

Trait Implementations

impl Operator for UnwindOperator

fn next(&mut self) -> OperatorResult

Returns the next chunk of data, or None if exhausted.

fn reset(&mut self)

Resets the operator to its initial state.

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

Returns the name of this operator for debugging.