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 supported65 Subscribers
Add a CodeTriage badge to beam
Help out
- Issues
- Retry ProcessPoolExecutor initialization on BrokenProcessPool in _SubprocessDoFn
- Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec
- [Bug]: [Python] ReadFromJson stores nested JSON objects and arrays as Python repr strings
- [Bug]: [Python] Type inference returns Any for attributes of NamedTuple-typed and nullable nested rows
- [Bug]: [Python] ReadFromParquet(as_rows=True) yields dicts for struct fields declared as Row
- [Bug]: [Python] WriteToParquet fails on schema'd PCollections whose nested struct fields hold beam.Row values
- [YAML] Skip non-identifier and keyword field names when binding Python expression variables
- [Bug]: [Python/YAML] MapToFields / Filter expression raises SyntaxError when schema contains Python keyword column names
- [Bug]: [Python] DirectRunner Prism fallback to BundleBasedDirectRunner fails with NotImplementedError on batched DoFns (WriteToParquet)
- [Bug]: [Java/YAML] StringCompiler fails to resolve org.apache.beam.sdk.values.Row inside Java SDK harness container
- Docs
- Java not yet supported