Skip to main content

execute_unwind

Function execute_unwind 

Source
pub fn execute_unwind(
    source_records: Vec<Record>,
    expr: &Expression,
    variable: &str,
    engine: &StorageEngine,
    params: &Params,
    scalar_fns: &dyn ScalarFnLookup,
) -> Result<Vec<Record>, ExecutionError>
Expand description

Execute UNWIND: for each source record, evaluate the expression. If the result is a List, emit one row per element with the variable bound. If the result is Null, emit zero rows (skip the source record). If the result is not a List and not Null, return an error.