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

Function window_functions_fn_wrapper

datafusion/ffi/src/execution/task_ctx.rs:139–151  ·  view source on GitHub ↗
(
    ctx: &FFI_TaskContext,
)

Source from the content-addressed store, hash-verified

137}
138
139unsafe extern "C" fn window_functions_fn_wrapper(
140 ctx: &FFI_TaskContext,
141) -> SVec<(SString, FFI_WindowUDF)> {
142 unsafe {
143 let ctx = ctx.inner();
144 ctx.window_functions()
145 .iter()
146 .map(|(name, udf)| {
147 (name.to_owned().into(), FFI_WindowUDF::from(Arc::clone(udf)))
148 })
149 .collect()
150 }
151}
152
153unsafe extern "C" fn release_fn_wrapper(ctx: &mut FFI_TaskContext) {
154 unsafe {

Callers

nothing calls this directly

Calls 6

collectMethod · 0.80
innerMethod · 0.45
mapMethod · 0.45
iterMethod · 0.45
window_functionsMethod · 0.45
intoMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…