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 supported35 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- [Feature Request]: ElasticSearchIO.Write to allow adding context to input json
- [Bug]: beam_PostCommit_Java_ValidatesRunner_Flink is flakes in org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests.testAfterProcessingTimeContinuationTriggerUsingState
- [Feature Request][Go SDK]: Have the Dataflow runner use the cloned GCR images instead if the image is unset.
- [Feature Request]: BigQuery Storage API read throttle
- Portable flink runner job server does not include Azure filesystem
- [Bug]: `Tuple` is confused for a `NamedTuple` across Python versions (3.9 vs 3.10).
- [Bug]: ParDo#with_exception_handling(use_subprocess=True) doesn't work because of missing _context.process_instruction_id
- [Task][Go SDK][Perf]: Make and use a general []byte buffer allocation pool for the SDK.
- [Bug]: Data not being forwarded correctly to Stateful DoFn in Python SDK + PortableRunner
- [Task]: Make beam.Row() more robust for cross-language use
- Docs
- Java not yet supported