Struct tidb_query_executors::limit_executor::BatchLimitExecutor

pub struct BatchLimitExecutor<Src: BatchExecutor> {
    src: Src,
    remaining_rows: usize,
    is_src_scan_executor: bool,
}

Executor that retrieves rows from the source executor and only produces part of the rows.

Fields

src: Src

remaining_rows: usize

is_src_scan_executor: bool

Implementations

impl<Src: BatchExecutor> BatchLimitExecutor<Src>

pub fn new(src: Src, limit: usize, is_src_scan_executor: bool) -> Result<Self>

Trait Implementations

impl<Src: BatchExecutor> BatchExecutor for BatchLimitExecutor<Src>

type StorageStats = Src::StorageStats

fn schema(&self) -> &[FieldType]

Gets the schema of the output.

fn next_batch(&mut self, scan_rows: usize) -> BatchExecuteResult

Pulls next several rows of data (stored by column).

fn collect_exec_stats(&mut self, dest: &mut ExecuteStats)

Collects execution statistics (including but not limited to metrics and execution summaries) accumulated during execution and prepares for next collection.

fn collect_storage_stats(&mut self, dest: &mut Self::StorageStats)

Collects underlying storage statistics accumulated during execution and prepares for next collection.

fn take_scanned_range(&mut self) -> IntervalRange

fn can_be_cached(&self) -> bool

fn collect_summary(
    self,
    output_index: usize
) -> WithSummaryCollector<ExecSummaryCollectorEnabled, Self> where
    Self: Sized,