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 supported33 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- [Bug]: Reject illformed GBK Coders
- [Task]: Build docker image for tensor RT tests during Run time and also provide Python 3.7, 3.9 Docker containers.
- [Bug]: XmlIO Exception in thread "main" java.lang.NoClassDefFoundError: javax/xml/bind/ValidationEventHandler
- [Bug]: SpannerIO.readChangeStream() stops forwarding change records and starts continuously throwing (large number) of Operation ongoing errors
- [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).
- Docs
- Java not yet supported