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
- [Flink] Spread start channels of consecutive senders in batch Reshuffle
- [Bug]: [SolaceIO] Reader fails with StaleSessionException and cannot recover after broker disconnect
- [Flink] Group partial combines by the structural value of the key
- [Bug]: [YAML] Bugs in Join wildcard fields, empty equalities check, and test spec validation
- [YAML] Fix Join wildcard fields, empty equalities check, and test spe…
- [#36841] Website: Spark 4 Structured Streaming runner supports streaming
- [YAML] Fix mapping expression validation, named chain outputs, and er…
- [Bug]: DataFrame API cov and corr diagonals ignore ddof and min_periods, and corr fails on a constant column
- Hold new-schema rows in UpdateSchemaDoFn until recognition window completes
- Avoid dropping record in _TruncatingFileHandle when restriction stop aligns with first record boundary
- Docs
- Java not yet supported