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
Add a CodeTriage badge to beam
Help out
- Issues
- Batching DoFn
- Improve efficiency of reading compressed text files
- HBaseIOTest fails tests if run from a directory with spaces
- Record type of state in Python InMemoryUnmergedState
- Support TimestampCombiner in Python streaming mode GroupByKey
- Give a option to ignore the timer that is larger than END_OF_GLOBAL_WINDOW
- Support PTransform overriding when input and output types are different
- Inconsistent behavior on the functioning of the dataflow templates?
- MR runner: add runner users guide under documentation/runners
- MR runner: update the capability matrix with the current status.
- Docs
- Java not yet supported