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 supported49 Subscribers
View all SubscribersAdd a CodeTriage badge to beam
Help out
- Issues
- [Task]: Improve the schema support for Beam 3.0
- [Feature Request]: Provide wheel for Windows ARM64
- [Disabled Test]: :runners:spark:3:test ResumeFromCheckpointStreamingTest testWithResume is disabled due to flake rate
- [Task]: YAML - E2E example pipelines for common use cases
- [GSOC 25] Enhanced Interactive Pipeline Development Environment for JupyterLab
- [Tracker]: Clean up spotbug suppressions after upgrading to SpotBugs 4.8
- [Bug]: WriteToPubSub silently failing to publish messages
- [Bug]: Request Size Limit Exceeded for ProtoRows with Large Payloads (Beyond Dismissed Edge Case)
- [Task]: Remove support of Samza runner in new Beam versions
- [Task]: Migrate Python SDK away from the google-apitools library
- Docs
- Java not yet supported