Struct tidb_query_executors::BatchSelectionExecutor

[+] Show declaration

pub struct BatchSelectionExecutor<Src: BatchExecutor> {
    context: EvalContext,
    src: Src,
    conditions: Vec<RpnExpression>,
}

Fields

context: EvalContext

src: Src

conditions: Vec<RpnExpression>

Implementations

impl BatchSelectionExecutor<Box<dyn BatchExecutor<StorageStats = ()>>>[−]

pub fn check_supported(descriptor: &Selection) -> Result<()>[−]

Checks whether this executor can be used.

impl<Src: BatchExecutor> BatchSelectionExecutor<Src>[−]

pub fn new(
    config: Arc<EvalConfig>,
    src: Src,
    conditions_def: Vec<Expr>
) -> Result<Self>

fn handle_src_result(
    &mut self,
    src_result: &mut BatchExecuteResult
) -> Result<()>[−]

Accepts source result and mutates its logical_rows according to predicates.

When errors are returned, it means there are errors during the evaluation. Currently we treat this situation as “completely failed”.

Trait Implementations

impl<Src: BatchExecutor> BatchExecutor for BatchSelectionExecutor<Src>[+]

[+] Show hidden undocumented items

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,