more docs

datafusion/core/src/datasource/cte_worktable.rs

@@ -46,6 +46,8 @@ pub struct CteWorkTable {
 
 impl CteWorkTable {
     /// construct a new CteWorkTable with the given name and schema
+    /// This schema must match the schema of the recursive term of the query
+    /// Since the scan method will contain an physical plan that assumes this schema
     pub fn new(name: &str, table_schema: SchemaRef) -> Self {
         Self {
             name: name.to_owned(),

datafusion/core/src/execution/context/mod.rs

@@ -1900,6 +1900,9 @@ impl<'a> ContextProvider for SessionContextProvider<'a> {
         Ok(provider_as_source(provider))
     }
 
+    /// 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
     fn create_cte_work_table(
         &self,
         name: &str,