Struct DistinctMaterializingOperator 

pub struct DistinctMaterializingOperator { /* private fields */ }

Push-based distinct operator that materializes all input first.

This is a true pipeline breaker that buffers all rows and produces distinct output in the finalize phase. Use this when you need deterministic ordering of output.

Implementations

impl DistinctMaterializingOperator

pub fn new() -> Self

Create a distinct operator on all columns.

pub fn on_columns(columns: Vec<usize>) -> Self

Create a distinct operator on specific columns.

Trait Implementations

impl Default for DistinctMaterializingOperator

fn default() -> Self

Returns the “default value” for a type.

impl PushOperator for DistinctMaterializingOperator

fn push( &mut self, chunk: DataChunk, _sink: &mut dyn Sink, ) -> Result<bool, OperatorError>

Process an incoming chunk and push results to the sink.

fn finalize(&mut self, sink: &mut dyn Sink) -> Result<(), OperatorError>

Called when all input has been processed.

fn preferred_chunk_size(&self) -> ChunkSizeHint

Hint for preferred chunk size.

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

Name of this operator for debugging.