Struct PoSqlContextProvider

pub struct PoSqlContextProvider<A: SchemaAccessor> { /* private fields */ }

A ContextProvider implementation for Proof of SQL

This provider is used to provide tables to the Proof of SQL planner

Implementations

impl<A: SchemaAccessor> PoSqlContextProvider<A>

pub fn new(accessor: A) -> Self

Create a new PoSqlContextProvider

Trait Implementations

impl<A: SchemaAccessor> ContextProvider for PoSqlContextProvider<A>

fn get_table_source( &self, name: TableReference, ) -> Result<Arc<dyn TableSource>, DataFusionError>

Getter for a datasource

fn get_function_meta(&self, _name: &str) -> Option<Arc<ScalarUDF>>

Getter for a UDF description

fn get_aggregate_meta(&self, _name: &str) -> Option<Arc<AggregateUDF>>

Getter for a UDAF description

fn get_window_meta(&self, _name: &str) -> Option<Arc<WindowUDF>>

Getter for a UDWF

fn get_variable_type(&self, _variable_names: &[String]) -> Option<DataType>

Getter for system/user-defined variable type

fn options(&self) -> &ConfigOptions

Get configuration options

fn udfs_names(&self) -> Vec<String>

fn udafs_names(&self) -> Vec<String>

fn udwfs_names(&self) -> Vec<String>

fn get_table_provider( &self, name: TableReference, ) -> Result<Arc<dyn TableSource>, DataFusionError>

👎Deprecated since 32.0.0: please use get_table_source instead

fn get_table_function_source( &self, _name: &str, _args: Vec<Expr>, ) -> Result<Arc<dyn TableSource>, DataFusionError>

Getter for a table function

fn create_cte_work_table( &self, _name: &str, _schema: Arc<Schema>, ) -> Result<Arc<dyn TableSource>, DataFusionError>

This provides a worktable (an intermediate table that is used to store the results of a CTE during execution) We don’t directly implement this in the logical plan’s [’SqlToRel] because the sql code needs access to a table that contains execution-related types that can't be a direct dependency of the sql crate (namely, the CteWorktable). The [ContextProvider`] provides a way to “hide” this dependency.