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

Method register_udaf

datafusion/execution/src/task.rs:212–221  ·  view source on GitHub ↗
(
        &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

Calls 6

iterMethod · 0.45
aliasesMethod · 0.45
insertMethod · 0.45
cloneMethod · 0.45
intoMethod · 0.45
nameMethod · 0.45

Tested by

no test coverage detected