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
- [PubsubIO] Add Read.withPullBatchSize()
- feat: add ability to configure slot reservations in BigQueryIO connector when using FILE_LOADS
- [Bug]: `WindmillMultimap` and `WindmillMap` `readLater()` skip in-memory cache checks, causing contagious cache-miss read amplification
- [Bug]: Typo in `IdTracker.writeValues()` calls `idsAvailable.clear()` instead of `idsAvailableValue.clear()`, leaking `OrderedListState` ID-tracking state in Windmill
- Update managed-io.md for release 2.78.0-RC4
- Avoid byte-offset splitting and truncation on compressed files in Go textio
- Rotate testcontainers SESSION_ID in cleanup_testcontainer_on_retry when Reaper fails
- [Feature Request]: [SQL/YAML] Add ML_PREDICT and VECTOR_SEARCH SQL TVFs backed by RunInference
- [Feature Request]: [SQL/YAML] Support ASOF JOIN for point-in-time streaming enrichment
- [Feature Request]: [State] Add declarative per-key StateSpec TTL and state schema evolution
- Docs
- Java not yet supported