[C++][Python] SubstraitSinkConsumer should handle backpressure
- Dominant language
- C++
- Stars
- 17.1k
- Forks
- 4.3k
- Avg merge
- 3d 13h
- Merged PRs (30d)
- 88
Description
Either we need to add backpressure to SubstraitSinkConsumer or (possibly easier) change SubstraitExecutor to use a SinkNode instead of a ConsumingSinkNode.
**Reporter**: [Weston Pace](https://issues.apache.org/jira/browse/ARROW-18025) / @westonpace
**Assignee**: [Vibhatha Lakmal Abeykoon](https://issues.apache.org/jira/browse/ARROW-18025) / @vibhatha
#### PRs and other links:
- [GitHub Pull Request #14487](https://github.com/apache/arrow/pull/14487)
- [GitHub Pull Request #14537](https://github.com/apache/arrow/pull/14537)
**Note**: *This issue was originally created as [ARROW-18025](https://issues.apache.org/jira/browse/ARROW-18025). Please see the [migration documentation](https://github.com/apache/arrow/issues/14542) for further details.*
Contributor guide
Research direction
Start by reviewing the SubstraitSinkConsumer and SubstraitExecutor discussion, then read GitHub pull requests #14487 and #14537 for prior work. Determine whether completion means adding backpressure to SubstraitSinkConsumer or changing SubstraitExecutor to use a SinkNode instead of a ConsumingSinkNode.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- cpp, python
- Domain
- data-engineering
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 20/100