Struct DefaultQueryExecutor 

pub struct DefaultQueryExecutor { /* private fields */ }

Default implementation of QueryExecutor

Implementations

impl DefaultQueryExecutor

pub fn new() -> Self

Create a new query executor

pub fn with_connector_registry(registry: ConnectorRegistry) -> Self

Create a query executor with a connector registry

Trait Implementations

impl Default for DefaultQueryExecutor

fn default() -> Self

Returns the “default value” for a type.

impl QueryExecutor for DefaultQueryExecutor

fn execute_plan<'life0, 'life1, 'async_trait>( &'life0 self, plan: &'life1 ExecutionPlan, ) -> Pin<Box<dyn Future<Output = NirvResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute an execution plan and return results

fn execute_node<'life0, 'life1, 'async_trait>( &'life0 self, node: &'life1 PlanNode, ) -> Pin<Box<dyn Future<Output = NirvResult<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a single plan node

fn set_connector_registry(&mut self, registry: ConnectorRegistry)

Set the connector registry for accessing data sources