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
Add a CodeTriage badge to beam
Help out
- Issues
- fix flaky python tests
- [Iceberg CDC sink] SchemaTransform (ManagedIO) layer
- [Iceberg CDC sink] Integration tests
- [Bug]: SpannerIO Change Streams may skip ChildPartitionsRecord when advancing tracker to artificial query end timestamp
- [BigQueryIO] Improve error message when BigQuery API is reported as not enabled
- Update Beam website to release 2.77.0
- [Bug]: Timestamp(float seconds) truncates instead of rounding, losing a microsecond
- [Python] Round float seconds to the nearest unit in Timestamp and Duration
- Clean up ruff breakage findings
- [Gemini] Prototype OpenAI RemoteInferenceModelHandler Implementation
- Docs
- Java not yet supported