Struct LimitCollector 

pub struct LimitCollector { /* private fields */ }

Collects first N rows across all partitions.

Stops collecting once the limit is reached (per partition). Final merge ensures exactly limit rows are returned.

Implementations

impl LimitCollector

pub fn new(limit: usize) -> Self

Creates a collector that limits output to limit rows.

Trait Implementations

impl Clone for LimitCollector

fn clone(&self) -> LimitCollector

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Collector for LimitCollector

type Fruit = (Vec<DataChunk>, usize)

Final result type after merging all partitions.

type PartitionCollector = LimitPartitionCollector

Partition-local collector type.

fn for_partition(&self, _partition_id: usize) -> Self::PartitionCollector

Creates a collector for a single partition (called per-thread).

fn merge(&self, fruits: Vec<(Vec<DataChunk>, usize)>) -> (Vec<DataChunk>, usize)

Merges results from all partitions (called once at the end).

impl Debug for LimitCollector

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

Formats the value using the given formatter.