Method task_ctx

datafusion/core/src/dataframe/mod.rs:1557–1559

Return a new [`TaskContext`] which would be used to execute this DataFrame

(&self)

    /// Return a new [`TaskContext`] which would be used to execute this DataFrame
    pub fn task_ctx(&self) -> TaskContext {
        TaskContext::from(self.session_state.as_ref())
    }

    /// Executes this DataFrame and returns a stream over a single partition
    ///