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 supported60 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Aggregated javadoc (:beam-sdks-java-javadoc:aggregateJavadoc) not running in nightly snapshot release
- Add Go SDK support for native Kafka IO on Flink
- Upgrade Bigquery to com.google.cloud library
- Set region when BigqueryIO.write using DirectRunner
- Consolidate Python Label Flag Handling
- Implement AssignWindows for known WindowFns in the ReferenceRunner
- Join the local-java and direct-java packages
- Implement the native Java DirectRunner via the ReferenceRunner and an InProcessServerFactory/Channel
- Python: Portable batch Flink runner passes all ValidatesRunner tests
- Python: FlinkPortableTestRunner: runs portably via self-started local Flink
- Docs
- Java not yet supported