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 supported55 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Make StateRequestHandler::accept interface idiomatic.
- Example of distributed optimization
- Contributor's guide needs to document how to install Python SDK from source
- Direct runner does not wait for failed tasks to teardown
- Flink runners fails on multioutput portable pipeline
- Artifact Retrieval Service Protocol should be able to serve multiple Manifests.
- Support Python ValidatesRunner test against TestDataflowRunner in streaming
- PTransformOverride does not replace side input usage of replaced transform
- SQL operators and primitive values should use a richer type system than SqlTypeName
- Investigate other encoding mechanism for SchemaCoder
- Docs
- Java not yet supported