Skip to main content

Executor

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§