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
- Increase Firestore test setup Future.get timeout from 10s to 60s in BaseFirestoreIT
- Retry catalog setup in IcebergCatalogBaseIT and IcebergCdcWriteBaseIT
- [Python] Fast-path _IntervalWindowBase.__init__ for int and Timestamp inputs
- [Java] Add `SecretCredentialsProvider` to resolve AWS credentials
- Avoid false-positive CheckGrafanaDataFreshness failures during quiet GitHub issue windows
- [Python] Fix the DataFrame cov and corr diagonals and corr of a constant column
- Check cancelFlag when PipelineResult.waitUntilFinish throws RuntimeException in BeamEnumerableConverter
- Reuse embedded FnHarness environment and isolate job IDs in Flink portable execution tests
- [Python] Optimize _IntervalWindowBase.__eq__ and __hash__
- [Python] Canonicalize _DoFnParam placeholders and use identity checks in PerWindowInvoker
- Docs
- Java not yet supported