beam
https://github.com/apache/beam
Java
Apache Beam is a unified programming model for Batch and Streaming data processing.
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported63 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Adds support to UngroupedWindmillReader for empty element metadata.
- Cherry-picking Iceberg CDC sink Java API layer
- [Task]: Update BigTable to Bigtable to match industry standards
- [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup
- [Java][BigQueryIO] Honor allowMissingRequiredFields when building Storage Write API messages
- [Feature Request]: Implement least-privilege access for GKE workload hosting Beam metrics.
- [Feature Request]: Update Beam Grafana instance
- [Python] Add reusable decision model primitives
- Address wrap-up items for Iceberg side input table cache
- update BigTable to Bigtable for non-yaml related files
- Docs
- Java not yet supported