Struct LimitOperator 

pub struct LimitOperator { /* private fields */ }

Limit operator.

Returns at most limit rows from the input.

Implementations

impl LimitOperator

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

Creates a new limit operator.

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

Decomposes this operator for push-based conversion.

Trait Implementations

impl Operator for LimitOperator

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.