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
- [Python] Avoid buffer malloc in Cython ByteCountingOutputStream and use bit_length in get_varint_size
- [Python] Do not modify input elements in the embedding output functions
- [Bug]: DataFrame API skew() and kurtosis() raise UnboundLocalError when all the data is in one partition
- [Python] Fix DataFrame skew() and kurtosis() with a single non-empty partition
- [Feature Request]: Add possibility of configuring per-job reservation slots in BigQueryIO connector
- [Bug]: Beam YAML SQL-backed Combine generates invalid syntax for `language: calcite` expressions and `language: sql` shorthand aggregations
- [YAML] Fix SQL-backed Combine query generation for Calcite expressions and SQL shorthand (#41288)
- [Python] Replace install-nvidia-driver:5xx Dataflow GPU option with '<...>:latest"
- Synchronize SingleEmitInputDStream batches with GlobalWatermarkHolder
- [Python] Hoist CompressionTypes lookup tables to class constants
- Docs
- Java not yet supported