(&self, name: &str)
| 201 | } |
| 202 | |
| 203 | fn udwf(&self, name: &str) -> Result<Arc<WindowUDF>> { |
| 204 | let result = self.window_functions.get(name); |
| 205 | |
| 206 | result.cloned().ok_or_else(|| { |
| 207 | internal_datafusion_err!( |
| 208 | "There is no UDWF named \"{name}\" in the TaskContext" |
| 209 | ) |
| 210 | }) |
| 211 | } |
| 212 | fn register_udaf( |
| 213 | &mut self, |
| 214 | udaf: Arc<AggregateUDF>, |