Struct datafusion::execution::context::ExecutionContextState

pub struct ExecutionContextState {
    pub catalog_list: Arc<dyn CatalogList>,
    pub scalar_functions: HashMap<String, Arc<ScalarUDF>>,
    pub aggregate_functions: HashMap<String, Arc<AggregateUDF>>,
    pub config: ExecutionConfig,
    pub execution_props: ExecutionProps,
    pub object_store_registry: Arc<ObjectStoreRegistry>,
    pub runtime_env: Arc<RuntimeEnv>,
}

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

aggregate_functions: HashMap<String, Arc<AggregateUDF>>

Aggregate functions registered in the context

config: ExecutionConfig

Context configuration

execution_props: ExecutionProps

Execution properties

object_store_registry: Arc<ObjectStoreRegistry>

Object Store that are registered with the context

runtime_env: Arc<RuntimeEnv>

Runtime environment

Implementations

impl ExecutionContextState

pub fn new() -> Self

Returns new ExecutionContextState

Trait Implementations

impl Clone for ExecutionContextState

fn clone(&self) -> ExecutionContextState

Returns a copy of the value.

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 Default for ExecutionContextState

fn default() -> Self

Returns the “default value” for a type.

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.