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 supported31 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- [Bug]: Exception from Downstream DoFn suppressed if upstream DoFn catches it on Dataflow Runner
- [Bug]: segmentation fault in WriteToFile with DirectRunner
- [Tracking]: Performance issue of PubSubIO on non-Dataflow runner
- [Task]: Use google-github-actions/auth@v2 to authenticate with google cloud SA
- [Feature Request]: Add custom counters tracking bytes read and written from the Google Cloud Storage in the GcsFileSystem
- Managed BigQueryIO
- [Bug][Prism]: unsupported URN beam:transform:redistribute_(arbitrarily|bykey):v1:Redistribute.Redistribute*
- [Bug][Prism]: unsupported feature "WindowingStrategy.Trigger" set with value (never|always)
- Auto Inference of JdbcIO#NumPartitions seems to be dead code.
- [Feature Request]: Add metric counting the number of bytes read/written from/to a GCS bucket
- Docs
- Java not yet supported