Complete user-initiated SDF functionality

ray-project / ray_beam_runner

Ray-based Apache Beam runner

Apache License 2.0

41 stars 12 forks source link

Closed iasoon closed 1 year ago

iasoon commented 1 year ago

Implement bundle finalization and support for drain mode. This should enable the full test suite for user-initiated SDF functionality to run.

pabloem commented 1 year ago

lgtm!