Repository navigation
Conversation
Share bounded partition execution, ordering, limits and cancellation between direct array consumers and the DataFusion v2 source. Co-authored-by: Codex <[email protected]> Signed-off-by: Nicholas Gates <[email protected]>
Merging this PR will improve performance by 29.47%2 warnings
Performance Changes
Tip Curious why performance improved? Comment Comparing Footnotes
|
Scan API consumers currently have to implement their own partition driver. Add
vortex_scan::driver::ScanDriverto produce lazy array streams with bounded partition read-ahead, independent output consumers, ordered concatenation, exact limits, and cancellation. Partition implementations retain ownership of runtime scheduling; the driver spawns no tasks.Reuse the driver in the DataFusion v2 source, leaving Arrow conversion and engine-specific planning in the adapter.
Validation: three focused driver tests, the existing DataFusion v2 tests, the scan doctest, and scoped all-targets/all-features Clippy pass.
Generated with Codex.