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

Function scalar_functions_fn_wrapper

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

Source from the content-addressed store, hash-verified

108}
109
110unsafe extern "C" fn scalar_functions_fn_wrapper(
111 ctx: &FFI_TaskContext,
112) -> SVec<(SString, FFI_ScalarUDF)> {
113 unsafe {
114 let ctx = ctx.inner();
115 ctx.scalar_functions()
116 .iter()
117 .map(|(name, udf)| (name.to_owned().into(), Arc::clone(udf).into()))
118 .collect()
119 }
120}
121
122unsafe extern "C" fn aggregate_functions_fn_wrapper(
123 ctx: &FFI_TaskContext,

Callers

nothing calls this directly

Calls 6

collectMethod · 0.80
innerMethod · 0.45
mapMethod · 0.45
iterMethod · 0.45
scalar_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…