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
- The PostCommit Java ValidatesRunner Dataflow Streaming TagEncodingV2 job is flaky
- [RunInference] Fix WatchFilePattern selecting the newest model
- Correct typo in the staged path.
- Fixes some bugs in WindmillMapViaMultimap.
- [Task]: Un-skip Iceberg CDC tests when Managed service gets updated to 2.77
- [Python] Add PTransform.with_annotations() for per-transform annotations
- [Bug]: Go SDK pipeline options define global flags with generic names, causing flag redefinition panics
- [Feature Request]: Support pandas 3+ in the dataframes API
- [Task]: Migrate Java SDK GcsUtil from gcsio to the java-storage client
- [Feature Request]: Attach RunInference model_identifier annotation only to the inference ParDo when with_exception_handling(threshold<1) is used
- Docs
- Java not yet supported