risingwave_batch::executor

Trait BoxedExecutorBuilder

source
pub trait BoxedExecutorBuilder {
    // Required method
    fn new_boxed_executor<'life0, 'life1, 'async_trait, C>(
        source: &'life0 ExecutorBuilder<'life1, C>,
        inputs: Vec<BoxedExecutor>,
    ) -> Pin<Box<dyn Future<Output = Result<BoxedExecutor>> + Send + 'async_trait>>
       where C: 'async_trait + BatchTaskContext,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

Every Executor should impl this trait to provide a static method to build a BoxedExecutor from proto and global environment.

Required Methods§

source

fn new_boxed_executor<'life0, 'life1, 'async_trait, C>( source: &'life0 ExecutorBuilder<'life1, C>, inputs: Vec<BoxedExecutor>, ) -> Pin<Box<dyn Future<Output = Result<BoxedExecutor>> + Send + 'async_trait>>
where C: 'async_trait + BatchTaskContext, 'life0: 'async_trait, 'life1: 'async_trait,

Object Safety§

This trait is not object safe.

Implementors§

source§

impl BoxedExecutorBuilder for DeleteExecutor

source§

impl BoxedExecutorBuilder for ExpandExecutor

source§

impl BoxedExecutorBuilder for FilterExecutor

source§

impl BoxedExecutorBuilder for GenericExchangeExecutorBuilder

source§

impl BoxedExecutorBuilder for GroupTopNExecutorBuilder

source§

impl BoxedExecutorBuilder for HashAggExecutorBuilder

source§

impl BoxedExecutorBuilder for HopWindowExecutor

source§

impl BoxedExecutorBuilder for IcebergScanExecutorBuilder

source§

impl BoxedExecutorBuilder for InsertExecutor

source§

impl BoxedExecutorBuilder for DistributedLookupJoinExecutorBuilder

source§

impl BoxedExecutorBuilder for HashJoinExecutor<()>

source§

impl BoxedExecutorBuilder for LocalLookupJoinExecutorBuilder

source§

impl BoxedExecutorBuilder for NestedLoopJoinExecutor

source§

impl BoxedExecutorBuilder for LimitExecutor

source§

impl BoxedExecutorBuilder for LogStoreRowSeqScanExecutorBuilder

source§

impl BoxedExecutorBuilder for MaxOneRowExecutor

source§

impl BoxedExecutorBuilder for MergeSortExchangeExecutorBuilder

source§

impl BoxedExecutorBuilder for MySqlQueryExecutorBuilder

source§

impl BoxedExecutorBuilder for SortExecutor

source§

impl BoxedExecutorBuilder for PostgresQueryExecutorBuilder

source§

impl BoxedExecutorBuilder for ProjectExecutor

source§

impl BoxedExecutorBuilder for ProjectSetExecutor

source§

impl BoxedExecutorBuilder for RowSeqScanExecutorBuilder

source§

impl BoxedExecutorBuilder for FileScanExecutorBuilder

source§

impl BoxedExecutorBuilder for SortAggExecutor

source§

impl BoxedExecutorBuilder for SortOverWindowExecutor

source§

impl BoxedExecutorBuilder for SourceExecutor

source§

impl BoxedExecutorBuilder for SysRowSeqScanExecutorBuilder

source§

impl BoxedExecutorBuilder for TableFunctionExecutorBuilder

source§

impl BoxedExecutorBuilder for BlockExecutorBuilder

source§

impl BoxedExecutorBuilder for BusyLoopExecutorBuilder

source§

impl BoxedExecutorBuilder for TopNExecutor

source§

impl BoxedExecutorBuilder for UnionExecutor

source§

impl BoxedExecutorBuilder for UpdateExecutor

source§

impl BoxedExecutorBuilder for ValuesExecutor