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§
sourcefn schema(&self) -> &Schema
fn schema(&self) -> &Schema
Returns the schema of the executor’s return data.
Schema must be available before init.
sourcefn execute(self: Box<Self>) -> BoxedDataChunkStream
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.