Trait LookupExecutorBuilder

pub trait LookupExecutorBuilder: Send {
    // Required methods
    fn reset(&mut self);
    fn add_scan_range<'life0, 'async_trait>(
        &'life0 mut self,
        key_datums: Vec<Datum>,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn build_executor<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<BoxedExecutor>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Used to build the executor for the inner side

Required Methods

fn reset(&mut self)

fn add_scan_range<'life0, 'async_trait>( &'life0 mut self, key_datums: Vec<Datum>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn build_executor<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<BoxedExecutor>> + Send + 'async_trait>>

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

Implementors

impl LookupExecutorBuilder for FakeInnerSideExecutorBuilder

impl<C: BatchTaskContext> LookupExecutorBuilder for risingwave_batch::executor::join::local_lookup_join::InnerSideExecutorBuilder<C>

impl<S: StateStore> LookupExecutorBuilder for risingwave_batch::executor::join::distributed_lookup_join::InnerSideExecutorBuilder<S>