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 supported55 Subscribers
View all SubscribersAdd a CodeTriage badge to beam
Help out
- Issues
- BigQueryIO WRITE_TRUNCATE documentation is out of date
- Improve / Fix documentation examples for Beam 2.4.0 for TextIO and BigQueryIO
- Remove redundant Checkstyle rules covered by ErrorProne
- Parquet IO position invalid when writing integers
- Make HBaseIO.read() based on SDF by default
- add functions to add/remove/list tables in BeamSqlEnv
- Allow combiner lifting with AfterProcessingTime trigger in Dataflow Runner
- [SQL][Feature Request] Infer Output schema
- Support INSERT OVERWRITE Statement
- DirectRunner assert_that should work in user state and timers tests
- Docs
- Java not yet supported