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
- 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
- Python: PortableRunner: p.run() starts a given JobService docker container and runs through it
- Docs
- Java not yet supported