beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
### What needs to happen? Create Terraform scripts for Tour of Beam project ### Issue Priority Priority: 3
### What needs to happen? Create Tour of Beam MVP application consisting of backend and frontend with the following functionality: - - landing page with table of contents and SDK...
### What needs to happen? Add Localization support for Tour of Beam frontend ### Issue Priority Priority: 3
### What needs to happen? Create Main page with table of contents, learning materials section and playground ### Issue Priority Priority: 3
[Tour of Beam] [Task] Backend API functions for getting module/unit content and examples source code
### What needs to happen? Create backend API functions for getting module/unit content and examples source code ### Issue Priority Priority: 3
------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R:...
**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...
The [beam-vendor-grpc-1_43_2](https://mvnrepository.com/artifact/org.apache.beam/beam-vendor-grpc-1_43_2) dependency (that is pulled transitively by the beam-runners-flink-1.13) shades a vulnerable Netty version, i.e. 4.1.63.Final: [https://mvnrepository.com/artifact/io.netty/netty-all/4.1.63.Final](https://mvnrepository.com/artifact/io.netty/netty-all/4.1.63.Final) In turn, our Beam pipelines builds are marked as vulnerable and we're...
Currently we can infer schemas for nested types, but only when they are homogenous (e.g. an AutoValue with an AutoValue field, or a Java Bean with a Java Bean field)....
This PR adds a new interface, `ShuffleCompressor`, which allows users to plug in compression for values just before they're written to shuffle. The interface is a little odd, we originally...
