Struct InMemoryFragmentExecutor 

pub struct InMemoryFragmentExecutor { /* private fields */ }

Reference FragmentExecutor over an InMemoryTableStore. Interprets scans, projections, partial aggregates, local merge sorts, bounded local top-ks (with exact tie information), and limits for real; exchange sources drain their input streams; join operators reject (their execution binding lands with the tablet wave — plan shape is fully tested).

Implementations

impl InMemoryFragmentExecutor

pub fn new(store: Arc<InMemoryTableStore>) -> Self

An executor over store that emits up to k top-k rows locally.

pub fn with_topk_emit_batch( store: Arc<InMemoryTableStore>, batch: usize, ) -> Self

Bounds the local top-k emission batch (refill exerciser).

Trait Implementations

impl FragmentExecutor for InMemoryFragmentExecutor

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, fragment: &'life1 PlanFragment, inputs: Vec<FragmentStream>, control: FragmentControl, ) -> Pin<Box<dyn Future<Output = DistributedResult<FragmentStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Runs the fragment. inputs carries one resolved stream per FragmentOperator::RemoteExchangeSource operator, in operator order.

fn refill_top_k( &self, fragment: &PlanFragment, offset: usize, limit: usize, ) -> DistributedResult<TopKRefill>

Returns the next limit local top-k candidates after offset (the number already returned), with a tightened unseen bound. Executors without scored streams leave the default, which rejects.