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§