ray-project / ray_beam_runner

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

DoFn state support #27

Closed iasoon closed 2 years ago

iasoon commented 2 years ago

Fixes the state handler to enable stateful DoFns closes #12

iasoon commented 2 years ago

r: @pabloem

pabloem commented 2 years ago

LGTM! thanks @iasoon