Module apply 

Apply (correlated subquery) execution plan for DataFusion.

Implements CALL { ... } subqueries by executing the subquery once per input row, injecting the input row’s columns as parameters, and cross-joining the results.

Semantics

For each row from the input plan:

1. Optionally filter via input_filter
2. Inject the input row’s columns as parameters
3. Re-plan and execute the subquery with those parameters
4. Cross-join: merge each subquery result row with the input row

If input produces zero rows (after filtering), execute the subquery once with the base parameters (standalone CALL support).

Structs

GraphApplyExec

Apply (correlated subquery) execution plan.