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
View all SubscribersAdd a CodeTriage badge to beam
Help out
- Issues
- fix bigtable schema issue
- Add examples for cloudsql
- [Bug]: pubsubio imports google.golang.org/genproto/googleapis/pubsub/v1, which was removed from current genproto releasess
- Keep progress renewal heartbeats active through bundle teardown
- [Bug]: Flink drops watermark holds for records awaiting a checkpoint
- [Python] Fail bundles on state write errors
- [Python] Reset BigQuery retries for each batch
- [Python] Isolate async work by key and window
- [Java] Preserve BigQuery failed rows across retries
- [Python] Finish async bundles after processing outputs
- Docs
- Java not yet supported