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 supported65 Subscribers
View all SubscribersAdd a CodeTriage badge to beam
Help out
- Issues
- [IcebergIO] Build read rows with attachValues
- [JmsIO] Acknowledge messages of checkpoints that are never finalized
- [Task]: Spark 4 streaming runner, support ParDo with additional outputs
- [Python] Fix WriteToFiles crashing when the sink writes compressed files
- [Spanner Change Streams] Replay aborted metadata transactions
- Update Beam website to release 2.78.0
- Clarify Beam initialization requirements in Go
- [Spanner Change Streams] Fix arrival order assumption in ordered IT
- [Go] Avoid importing jobopts in xlangx to prevent flag collisions
- [Python][RunInference] vLLM: prefix-aware batching and capacity-based autoscaling
- Docs
- Java not yet supported