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 supported65 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Allow disk use in MongoDbIO aggregations to avoid sort memory limit
- Test TriggerAfterSynchronizedProcessingTime without Repeat wrapper in windowinto.go
- Pass explicit timestamps for DirectRow.commit setup writes in Bigtable ITs
- [Bug]: MajorityVote tie_breaker ignores a custom normal_label
- [Bug]: MLTransform and RAG embedding output functions modify their input elements
- [Python] Optimize TimestampPrefixingWindowCoderImpl and ParamWindowedValueCoderImpl
- [Python] Add Cython StrUtf8CoderImpl and optimize BytesCoderImpl
- [Python] Optimize TupleCoderImpl, SequenceCoderImpl, and component size estimation
- [Python] Unroll 2-component KV fast path in AbstractComponentCoderImpl
- [Feature Request]: [Python] Add Variance, StandardDeviation, Covariance, and LinearRegression to apache_beam.transforms.combiners
- Docs
- Java not yet supported