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 supported60 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- [Bug]: RowJson rejects integral JSON values for a DOUBLE field when they exceed int range
- Accept integral JSON values that a double represents exactly
- [Java] Bound the Watch deduplication state with a timestamp cursor
- [Feature Request]: Implement Side-Input Table Cache for IcebergIO
- [Iceberg compaction] Rewrite subgroups DoFn
- [Iceberg compaction] Add committer DoFn
- fix: poll publish results from all producers in SolaceIO writer
- [Bug]: DynamoDB AttributeValueCoder cannot encode an empty list or empty map attribute
- Encode DynamoDB empty list and empty map attributes
- fix: allow empty DynamoDB list and map in AttributeValueCoder
- Docs
- Java not yet supported