Struct datafusion::execution::context::TaskContext

pub struct TaskContext { /* private fields */ }

Task Execution Context

Implementations

impl TaskContext

pub fn new(
    task_id: String,
    session_id: String,
    task_props: HashMap<String, String>,
    scalar_functions: HashMap<String, Arc<ScalarUDF>>,
    aggregate_functions: HashMap<String, Arc<AggregateUDF>>,
    runtime: Arc<RuntimeEnv>
) -> Self

Create a new task context instance

pub fn session_config(&self) -> SessionConfig

Return the SessionConfig associated with the Task

pub fn session_id(&self) -> String

Return the session_id of this TaskContext

pub fn task_id(&self) -> Option<String>

Return the task_id of this TaskContext

pub fn runtime_env(&self) -> Arc<RuntimeEnv>

Return the RuntimeEnv associated with this TaskContext

Trait Implementations

impl From<&'_ SessionContext> for TaskContext

Create a new task context instance from SessionContext

fn from(session: &SessionContext) -> Self

Converts to this type from the input type.

impl From<&'_ SessionState> for TaskContext

Create a new task context instance from SessionState

fn from(state: &SessionState) -> Self

Converts to this type from the input type.

impl FunctionRegistry for TaskContext

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.