Struct ClickHouseContextProvider 

pub struct ClickHouseContextProvider { /* private fields */ }

Custom ContextProvider

Required since DataFusion will throw an error on unrecognized functions and the goal is to preserve the Expr structure.

Implementations

impl ClickHouseContextProvider

pub fn new( state: SessionState, tables: HashMap<ResolvedTableReference, Arc<dyn TableSource>>, ) -> Self

pub fn with_expr_planner(self, planner: Arc<dyn ExprPlanner>) -> Self

pub fn with_type_planner(self, type_planner: Arc<dyn TypePlanner>) -> Self

Trait Implementations

impl ContextProvider for ClickHouseContextProvider

fn create_cte_work_table( &self, name: &str, schema: SchemaRef, ) -> Result<Arc<dyn TableSource>>

Create a new CTE work table for a recursive CTE logical plan This table will be used in conjunction with a Worktable physical plan to read and write each iteration of a recursive CTE

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

Return the scalar function with a given name, if any

fn get_expr_planners(&self) -> &[Arc<dyn ExprPlanner>]

Return ExprPlanner extensions for planning expressions

fn get_type_planner(&self) -> Option<Arc<dyn TypePlanner>>

Return TypePlanner extensions for planning data types

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

Returns a table by reference, if it exists

fn get_table_function_source( &self, name: &str, args: Vec<Expr>, ) -> Result<Arc<dyn TableSource>>

Getter for a table function

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

Return the aggregate function with a given name, if any

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

Return the window function with a given name, if any

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

Return the system/user-defined variable type, if any

fn options(&self) -> &ConfigOptions

Return overall configuration options

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

Return all scalar function names

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

Return all aggregate function names

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

Return all window function names

fn get_file_type(&self, ext: &str) -> Result<Arc<dyn FileType>>

Return the type of a file based on its extension (e.g. .parquet)