Registers all enabled packages with a [`FunctionRegistry`]
(
registry: &mut dyn FunctionRegistry,
)
| 83 | } |
| 84 | /// Registers all enabled packages with a [`FunctionRegistry`] |
| 85 | pub fn register_all( |
| 86 | registry: &mut dyn FunctionRegistry, |
| 87 | ) -> datafusion_common::Result<()> { |
| 88 | let functions: Vec<Arc<WindowUDF>> = all_default_window_functions(); |
| 89 | |
| 90 | functions.into_iter().try_for_each(|fun| { |
| 91 | let existing_udwf = registry.register_udwf(fun)?; |
| 92 | if let Some(existing_udwf) = existing_udwf { |
| 93 | debug!("Overwrite existing UDWF: {}", existing_udwf.name()); |
| 94 | } |
| 95 | Ok(()) as datafusion_common::Result<()> |
| 96 | })?; |
| 97 | |
| 98 | Ok(()) |
| 99 | } |
nothing calls this directly
no test coverage detected
searching dependent graphs…