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

Method register_udaf

datafusion/core/src/execution/context/mod.rs:1641–1643  ·  view source on GitHub ↗

Registers an aggregate UDF within this context. Note in SQL queries, aggregate names are looked up using lowercase unless the query uses quotes. For example, - `SELECT MY_UDAF(x)...` will look for an aggregate named `"my_udaf"` - `SELECT "my_UDAF"(x)` will look for an aggregate named `"my_UDAF"`

(&self, f: AggregateUDF)

Source from the content-addressed store, hash-verified

1639 /// - `SELECT MY_UDAF(x)...` will look for an aggregate named `"my_udaf"`
1640 /// - `SELECT "my_UDAF"(x)` will look for an aggregate named `"my_UDAF"`
1641 pub fn register_udaf(&self, f: AggregateUDF) {
1642 self.state.write().register_udaf(Arc::new(f)).ok();
1643 }
1644
1645 /// Registers a window UDF within this context.
1646 ///

Callers 15

simple_udafFunction · 0.45
advanced_udafFunction · 0.45
roundtrip_aggregate_udafFunction · 0.45
roundtrip_aggregate_udfFunction · 0.45
roundtrip_windowFunction · 0.45
register_allFunction · 0.45
create_functionMethod · 0.45
udaf_as_window_funcFunction · 0.45
simple_udafFunction · 0.45
deregister_udafFunction · 0.45

Calls 2

newFunction · 0.85
writeMethod · 0.45

Tested by 11

roundtrip_aggregate_udafFunction · 0.36
roundtrip_aggregate_udfFunction · 0.36
roundtrip_windowFunction · 0.36
udaf_as_window_funcFunction · 0.36
simple_udafFunction · 0.36
deregister_udafFunction · 0.36
test_groups_accumulatorFunction · 0.36
registerMethod · 0.36
roundtrip_aggregate_udfFunction · 0.36