Struct datafusion::execution::context::ExecutionContextState

pub struct ExecutionContextState {
    pub catalog_list: Arc<dyn CatalogList>,
    pub scalar_functions: HashMap<String, Arc<ScalarUDF>>,
    pub var_provider: HashMap<VarType, Arc<dyn VarProvider + Send + Sync>>,
    pub aggregate_functions: HashMap<String, Arc<AggregateUDF>>,
    pub config: ExecutionConfig,
}

Execution context for registering data sources and executing queries

Fields

catalog_list: Arc<dyn CatalogList>

Collection of catalogs containing schemas and ultimately TableProviders

scalar_functions: HashMap<String, Arc<ScalarUDF>>

Scalar functions that are registered with the context

var_provider: HashMap<VarType, Arc<dyn VarProvider + Send + Sync>>

Variable provider that are registered with the context

aggregate_functions: HashMap<String, Arc<AggregateUDF>>

Aggregate functions registered in the context

config: ExecutionConfig

Context configuration

Trait Implementations

impl Clone for ExecutionContextState

fn clone(&self) -> ExecutionContextState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ContextProvider for ExecutionContextState

fn get_table_provider(
    &self,
    name: TableReference<'_>
) -> Option<Arc<dyn TableProvider>>

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

impl FunctionRegistry for ExecutionContextState

fn udfs(&self) -> HashSet<String>

Set of all available udfs.

fn udf(&self, name: &str) -> Result<Arc<ScalarUDF>>

Returns a reference to the udf named name.

fn udaf(&self, name: &str) -> Result<Arc<AggregateUDF>>

Returns a reference to the udaf named name.