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 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

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.