Struct Executor 

pub struct Executor(/* private fields */);

Implementations

impl Executor

pub fn new( functions: Functions, flow_operator_store: FlowOperatorStore, stats_tracker: StorageTracker, ) -> Self

pub fn with_virtual_table_registry( functions: Functions, flow_operator_store: FlowOperatorStore, virtual_table_registry: TableVirtualUserRegistry, stats_tracker: StorageTracker, ) -> Self

pub fn testing() -> Self

impl Executor

pub async fn execute_command_plan<'a>( &self, txn: &'a mut StandardCommandTransaction, plan: PhysicalPlan, params: Params, stack: &mut Stack, ) -> Result<Option<Columns>>

Trait Implementations

impl Clone for Executor

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Deref for Executor

type Target = ExecutorInner

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl ExecuteCommand<StandardCommandTransaction> for Executor

fn execute_command<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 mut StandardCommandTransaction, cmd: Command<'life2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Frame>>> + Send + 'async_trait>>

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

impl ExecuteQuery<StandardQueryTransaction> for Executor

fn execute_query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, txn: &'life1 mut StandardQueryTransaction, qry: Query<'life2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Frame>>> + Send + 'async_trait>>

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

impl Execute<StandardCommandTransaction, StandardQueryTransaction> for Executor