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 supported56 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Create a CLI to convert a pipeline to graphviz dot format
- Remove experimental annotation from stable transforms in Java BigTableIO connector
- Cloud Bigtable IO connector can read from multiple tables using SDF (Java)
- Add query support to DynamoDBIO
- support hash_fn for Python ApproximateUniqueCombineFn transform
- Make VarIntCoder overflow behavior consistent
- Add exception handling to Filter in Java SDK
- HllCount does not work on Dataflow FnAPI workers
- remove ambiguity of Setup/StartBundle javadocs in DoFn
- Template parameters don't work if they are only used in DoFns
- Docs
- Java not yet supported