Method
register_udaf
(
&mut self,
udaf: Arc<AggregateUDF>,
)
Source from the content-addressed store, hash-verified
| 210 | }) |
| 211 | } |
| 212 | fn register_udaf( |
| 213 | &mut self, |
| 214 | udaf: Arc<AggregateUDF>, |
| 215 | ) -> Result<Option<Arc<AggregateUDF>>> { |
| 216 | udaf.aliases().iter().for_each(|alias| { |
| 217 | self.aggregate_functions |
| 218 | .insert(alias.clone(), Arc::clone(&udaf)); |
| 219 | }); |
| 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 |
Callers
nothing calls this directly
Tested by
no test coverage detected