| 220 | Ok(self.aggregate_functions.insert(udaf.name().into(), udaf)) |
| 221 | } |
| 222 | fn register_udwf(&mut self, udwf: Arc<WindowUDF>) -> Result<Option<Arc<WindowUDF>>> { |
| 223 | udwf.aliases().iter().for_each(|alias| { |
| 224 | self.window_functions |
| 225 | .insert(alias.clone(), Arc::clone(&udwf)); |
| 226 | }); |
| 227 | Ok(self.window_functions.insert(udwf.name().into(), udwf)) |
| 228 | } |
| 229 | fn register_udf(&mut self, udf: Arc<ScalarUDF>) -> Result<Option<Arc<ScalarUDF>>> { |
| 230 | udf.aliases().iter().for_each(|alias| { |
| 231 | self.scalar_functions |