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 supported49 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Implement pluggable Lineage in Java SDK
- Fix WriteToPubSub to pass ordering_key to publish() method
- Plumb custom batch parameters for autosharding from WriteFiles to FileIO.
- [Feature Request]: Expose message publish time in Beam YAML ReadFromPubSub
- Exposed source window to AssignContext in window_mapping_fn for side inputs
- feat: Adds support for DATE, DATETIME and JSON BigQuery types in the Python SDK using Storage API
- Fix flaky DataflowRunnerTest by ignoring batch tests in streaming mode
- [OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness
- Fix triggering frequency documentation validation
- Replace VarInt.getLength with Protobuf's branchless implementation
- Docs
- Java not yet supported