MCPcopy Create free account
hub / github.com/apache/datafusion / register_all

Function register_all

datafusion/functions-window/src/lib.rs:85–99  ·  view source on GitHub ↗

Registers all enabled packages with a [`FunctionRegistry`]

(
    registry: &mut dyn FunctionRegistry,
)

Source from the content-addressed store, hash-verified

83}
84/// Registers all enabled packages with a [`FunctionRegistry`]
85pub 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}

Callers

nothing calls this directly

Calls 3

into_iterMethod · 0.45
register_udwfMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…