Method create_cte_work_table

datafusion/core/src/execution/session_state.rs:2002–2011

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

(
        &self,
        name: &str,
        schema: arrow::datatypes::SchemaRef,
    )

    /// This table will be used in conjunction with a Worktable physical plan
    /// to read and write each iteration of a recursive CTE
    fn create_cte_work_table(
        &self,
        name: &str,
        schema: arrow::datatypes::SchemaRef,
    ) -> datafusion_common::Result<Arc<dyn TableSource>> {
        let table = Arc::new(crate::datasource::cte_worktable::CteWorkTable::new(
            name, schema,
        ));
        Ok(provider_as_source(table))
    }

    fn get_function_meta(&self, name: &str) -> Option<Arc<ScalarUDF>> {
        self.state.scalar_functions().get(name).cloned()