(&self, name: &str)
| 193 | } |
| 194 | |
| 195 | fn udaf(&self, name: &str) -> Result<Arc<AggregateUDF>> { |
| 196 | let result = self.aggregate_functions.get(name); |
| 197 | |
| 198 | result.cloned().ok_or_else(|| { |
| 199 | plan_datafusion_err!("There is no UDAF named \"{name}\" in the TaskContext") |
| 200 | }) |
| 201 | } |
| 202 | |
| 203 | fn udwf(&self, name: &str) -> Result<Arc<WindowUDF>> { |
| 204 | let result = self.window_functions.get(name); |