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 supported56 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Support joda time and java time Duration in schema inference
- Error occurred when transforming from row to a new row without setCoder
- Support custom gcs location for bigquery read
- Modify behavior of Dynamic Destinations
- Resolve differences in beam:metric:element_count:v1 implementations
- Mongo cursor timeout leads to CursorNotFound error
- Reduce PreCommit test to the minimum and move rest of them to PostCommit one
- Do not hardcode Python versions in test suites, instead make it configurable.
- Priotize Python versions for PreCommit/PostCommit tests
- Non-insertion errors in BigQueryIO.Write cause infinite loop
- Docs
- Java not yet supported