Skip to content

Pull requests: apache/beam

New pull request New
Clear current search query, filters, and sorts
8 Open 320 Closed
8 Open 320 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[yaml] - add max_read_time_seconds support to PubSub gcp io java python runners yaml
#36698 opened Oct 31, 2025 by derrickaw • Draft
3 tasks
3
Split some dependencies out of main beam package into existing extras gcp io python runners yaml
#36697 opened Oct 31, 2025 by damccorm • Draft
3 tasks
1
Add documentation and examples for SQL calcite_connection… Next Action: Author python yaml
#36684 opened Oct 30, 2025 by cipheraxat Loading…
1 task done
1
12
Add Iceberg CDC support to YAML and Blueprints Next Action: Reviewers python yaml
#36641 opened Oct 27, 2025 by tarun-google Loading…
4
[yaml]: add kafka parameter explicitly and uncover kafka test python yaml
#36603 opened Oct 23, 2025 by derrickaw • Draft
3 tasks
2
Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable aws bigtable build core dataflow direct docker examples extensions flink fn-execution gcp go hadoop hbase hcatalog healthcare infra io java jdbc jet jms kafka learning local model mongodb mqtt Next Action: Reviewers parquet prism protobuf python runners samza sketching spanner spark sql synthetic tests thrift twister2 typescript vendor website yaml
#35589 opened Jul 15, 2025 by talatuyarer Loading…
3 tasks
1
21
Add Kafka to Kafka RAW example pipeline configuration Next Action: Author python reassigned-reviewers yaml
#34992 opened May 18, 2025 by Ashfaqbs Loading…
23
Request to use BASIC enum when calling tables.get() in BigQuery #34075 gcp io python yaml
#34249 opened Mar 11, 2025 by tamannakakkar93 • Draft
15
ProTip! Add no:assignee to see everything that’s not assigned.