risingwave_batch::executor

Trait Executor

source 
pub trait Executor: Send + 'static {
    // Required methods
    fn schema(&self) -> &Schema;
    fn identity(&self) -> &str;
    fn execute(self: Box<Self>) -> BoxedDataChunkStream;
}
Expand description

Refactoring of Executor using Stream.

Required Methods§

source

fn schema(&self) -> &Schema

Returns the schema of the executor’s return data.

Schema must be available before init.

source

fn identity(&self) -> &str

Identity string of the executor

source

fn execute(self: Box<Self>) -> BoxedDataChunkStream

Executes to return the data chunk stream.

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

Implementors§