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 supported63 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime
- [Feature Request]: Avoid per-field `Descriptor.findFieldByName` lookups in BigQuery Storage Write API TableRow conversion
- [Feature Request]: Honor `allowMissingRequiredFields` when building Storage Write API messages from TableRow
- Add OpenTelemetry tracing support to SolaceIO
- [Feature Request]: Allow ADK Model Handler to use local models
- Remove upper bound pin for cryptography.
- [KafkaIO] Add `with_gcp_adc` and `num_partitions` options to Kafka SchemaTransforms and YAML
- Fix JaCoCo coverage for multiple test tasks.
- [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments
- [Go SDK] PostgreSQLIO core configuration, write sinks
- Docs
- Java not yet supported