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
- [Task]: Tighten the late data bound of the Spark 4 streaming stateful ParDo to the previous batch watermark
- [Task]: Use Timestamp logical type in Beam SQL
- Remove whitespace for generated managed doc
- [Java] FirestoreIO: ramp up writes from a pipeline-wide start time
- [Claude] Produce Beam-specific representation of BQ resources, rework compat shims
- add pubsub max_read_time_seconds parameter
- [Claude] Capture behavior of the BigQueryWrapper during requests
- [Java] ParquetIO: resolve file records against the read schema
- [Python] Validate FileBasedSink num_shards type
- [Java] Bound pending Watch results per poll
- Docs
- Java not yet supported