Struct DistinctOperator 

pub struct DistinctOperator { /* private fields */ }

Distinct operator.

Removes duplicate rows from the input. Can operate on all columns or a subset.

Implementations

impl DistinctOperator

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

Creates a new distinct operator that considers all columns.

pub fn into_parts(self) -> (Box<dyn Operator>, Option<Vec<usize>>)

Decomposes this operator for push-based conversion.

pub fn on_columns( child: Box<dyn Operator>, columns: Vec<usize>, output_schema: Vec<LogicalType>, ) -> Self

Creates a distinct operator that considers only specified columns.

Trait Implementations

impl Operator for DistinctOperator

fn next(&mut self) -> OperatorResult

Pulls the next batch of data. Returns None when exhausted.

fn reset(&mut self)

Resets to initial state so you can iterate again.

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

Returns a name for debugging/explain output.

fn into_any(self: Box<Self>) -> Box<dyn Any + Send>

Converts this boxed operator into Box<dyn Any> for type-based dispatch.