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 supported33 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- [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
- [Bug]: Issue with IllegalStateException in `STORAGE_WRITE_API` method in `BigQueryIO`
- [Feature Request]: Modernize content on supplying a pipeline as a package
- [prism] Triggers and Panes and Windowing Strategies
- Docs
- Java not yet supported