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
Add a CodeTriage badge to beam
Help out
- Issues
- Clear idsAvailableValue when idsAvailable becomes empty in IdTracker
- Check in-memory cache before queuing reads in WindmillMultimap and WindmillMap
- update TLDR to be more important in /summarize-failures
- add zizmor retries in workflow
- Fix ADKAgentModelHandler session reuse
- [Python] Infer NamedTuple and nullable nested row attribute types
- Fix: Set idLabel on messages written by the batch Pub/Sub sink
- [DebeziumIO] Enable Schema Change Events in DebeziumIO JSON Output
- [Python] Support process_batch-only DoFns in BundleBasedDirectRunner
- Return rows of unbounded Beam SQL queries while the pipeline runs
- Docs
- Java not yet supported