(&self, name: &str)
| 234 | } |
| 235 | |
| 236 | fn udwf(&self, name: &str) -> Result<Arc<WindowUDF>> { |
| 237 | self.udwfs |
| 238 | .get(name) |
| 239 | .cloned() |
| 240 | .ok_or_else(|| plan_datafusion_err!("Window Function {name} not found")) |
| 241 | } |
| 242 | |
| 243 | fn register_udf(&mut self, udf: Arc<ScalarUDF>) -> Result<Option<Arc<ScalarUDF>>> { |
| 244 | Ok(self.udfs.insert(udf.name().to_string(), udf)) |
no test coverage detected