search

ray-project / ray_beam_runner

Ray-based Apache Beam runner
Apache License 2.0
41 stars 12 forks source link

Support combiner lifting #16

Closed pabloem closed 2 years ago

pabloem commented 2 years ago

I am not sure why this test is not working properly, so this mainly involves figuring out what's going on in this test: https://github.com/ray-project/ray_beam_runner/blob/master/ray_beam_runner/portability/ray_runner_test.py#L796-L803

pabloem commented 2 years ago

Useful literature: https://s.apache.org/beam-fn-api