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
- improve yaml schema validation error message
- Bump cloud.google.com/go/bigquery from 1.66.2 to 1.67.0 in /sdks
- Bump github.com/docker/docker from 28.0.1+incompatible to 28.0.4+incompatible in /sdks
- Fn Runner Watermark issue
- SnowflakeIO: filter on db and schema when searching for existing table
- Setting num_bytes to DEFAULT_READ_BUFFER_SIZE if it is None originally
- Add the simple RC workflow to validate Go SDK with wordcount
- [Feature Request]: Enable to capture Kafka errors like JMSWriteResult
- [Task]: Create RC validation workflows
- chore: test beam against protobuf 3.25
- Docs
- Java not yet supported