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 supported35 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Cast function cannot convert value of type INTEGER to type BOOLEAN
- Remove Java version limit for classic Java runners
- Alias name not taking effect in a "over window" query with Beam SQL
- Support DDL in Python SqlTransform
- GCP DataFlow not cleaning up GCP BigQuery temporary datasets
- DoFn lifecycle in programming guide should be updated with portable execution
- Guardrails around fromTopic (pubsub)
- Unable to subscribe to several PubSub subscriptions with a valueprovider
- Support file checksum throughout filesystems
- AutoValueSchema has no way to override field schemas
- Docs
- Java not yet supported