Trait Executor

pub trait Executor: Send + 'static {
    // Required methods
    fn schema(&self) -> &Schema;
    fn identity(&self) -> &str;
    fn execute(
        self: Box<Self>,
    ) -> Pin<Box<dyn Stream<Item = Result<DataChunk, BatchError>> + Send>>;
}

Refactoring of Executor using Stream.

Required Methods

fn schema(&self) -> &Schema

Returns the schema of the executor’s return data.

Schema must be available before init.

fn identity(&self) -> &str

Identity string of the executor

fn execute( self: Box<Self>, ) -> Pin<Box<dyn Stream<Item = Result<DataChunk, BatchError>> + Send>>

Executes to return the data chunk stream.

The implementation should guaranteed that each DataChunk’s cardinality is not zero.

Trait Implementations

impl Debug for Box<dyn Executor>

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

Implementors

impl Executor for AzblobFileScanExecutor

impl Executor for GcsFileScanExecutor

impl Executor for S3FileScanExecutor

impl Executor for BufferChunkExecutor

impl Executor for DeleteExecutor

impl Executor for DummyExecutor

impl Executor for ExpandExecutor

impl Executor for FilterExecutor

impl Executor for HopWindowExecutor

impl Executor for IcebergScanExecutor

impl Executor for InsertExecutor

impl Executor for LimitExecutor

impl Executor for ManagedExecutor

impl Executor for MaxOneRowExecutor

impl Executor for MergeSortExecutor

impl Executor for MySqlQueryExecutor

impl Executor for NestedLoopJoinExecutor

impl Executor for PostgresQueryExecutor

impl Executor for ProjectExecutor

impl Executor for ProjectSetExecutor

impl Executor for SortAggExecutor

impl Executor for SortExecutor

impl Executor for SortOverWindowExecutor

impl Executor for SourceExecutor

impl Executor for TableFunctionExecutor

impl Executor for TopNExecutor

impl Executor for UnionExecutor

impl Executor for UpdateExecutor

impl Executor for ValuesExecutor

impl Executor for WrapStreamExecutor

impl Executor for SysRowSeqScanExecutor

impl Executor for BlockExecutor

impl Executor for BusyLoopExecutor

impl Executor for MockExecutor

impl<CS: 'static + Send + CreateSource> Executor for GenericExchangeExecutor<CS>

impl<CS: 'static + Send + CreateSource> Executor for MergeSortExchangeExecutorImpl<CS>

impl<K: HashKey + Send + Sync> Executor for HashAggExecutor<K>

impl<K: HashKey> Executor for DistributedLookupJoinExecutor<K>

impl<K: HashKey> Executor for GroupTopNExecutor<K>

impl<K: HashKey> Executor for HashJoinExecutor<K>

impl<K: HashKey> Executor for LocalLookupJoinExecutor<K>

impl<S: StateStore> Executor for LogRowSeqScanExecutor<S>

impl<S: StateStore> Executor for RowSeqScanExecutor<S>