GH-45434: [C++][Acero] Add pipe_sink, pipe_source and pipe_tee nodes#45435

Draft

gitmodimo wants to merge 43 commits intoapache:mainfrom

gitmodimo:arrowPipeNoQueue

Commits on Aug 21, 2025

Add BackpressureCombiner
Rafał Hibner
committed
Init atomic
Rafał Hibner
committed
Move BackpressureController from Asofasof_join_node and sorted_merge_node to common backpressure
Rafał Hibner
committed
Add new files to meson
Rafał Hibner
committed
Add Wrapper and fix empty weak case
Rafał Hibner
committed
Do not export template?
Rafał Hibner
committed

Commits on Aug 22, 2025

Simplify backpressure combiner logic
Rafał Hibner
committed
Update doc
Rafał Hibner
committed

Commits on Sep 10, 2025

Include suggestion

gitmodimo
and
zanmato1984
authored
Include suggestion

gitmodimo
and
zanmato1984
authored

Commits on Oct 2, 2025

Add stop in backpressure combiner
Rafał Hibner
committed
Merge branch 'BackpressureCombiner' of https://github.com/gitmodimo/arrow into BackpressureCombiner
Rafał Hibner
committed
Merge branch 'main' into BackpressureCombiner
Rafał Hibner
committed
Initial implementation od acero pipes
Rafał Hibner
committed
Export PipeSource
Rafał Hibner
committed
Revert "Export PipeSource"
Rafał Hibner
committed
Forward ordering information
Rafał Hibner
committed
init pointer to fix unconncted pipe detection
Rafał Hibner
committed
annotate ovvrided method
Rafał Hibner
committed
fix implicit ordering check
Rafał Hibner
committed
Add method to check for pipe sources present
Rafał Hibner
committed
Check schema for matched pieps
Rafał Hibner
committed
Fix test
Rafał Hibner
committed
Add test multiple schemas
Rafał Hibner
committed
Check for duplicate pipe sinks
Rafał Hibner
committed
Cleanup and doc
Rafał Hibner
committed
sink_node can use sync source
Rafał Hibner
committed
Fix implicit infer from ordered
Rafał Hibner
committed
Handle StopProcessing over pipe
Rafał Hibner
committed
Expose stop strategy and add pause strategy
Rafał Hibner
committed
Fix uninitialized atomics
Rafał Hibner
committed
Respect StopProducing for pipe_sources. Unpause on stop.
Rafał Hibner
committed
Propagate ordering through pipe_tee
Rafał Hibner
committed
Rebase fix
Rafał Hibner
committed
Remove unneded include
Rafał Hibner
committed
Fix meson build
Rafał Hibner
committed
Remove redundant move
Rafał Hibner
committed
Use arrow mutex implementation
Rafał Hibner
committed
Update backpressure counter
Rafał Hibner
committed
fix namespace
Rafał Hibner
committed
Use BackpressureCombiner
Rafał Hibner
committed
Move unpause when stop logic to PipeSource
Rafał Hibner
committed
Add missing declaration
Rafał Hibner
committed