snuspl / nemo

Nemo: A flexible data processing system
https://snuspl.github.io/nemo/
Apache License 2.0
22 stars 6 forks source link

[Minor] Fix Broadcast Edge Annotation #754

Closed sanha closed 6 years ago

sanha commented 6 years ago

This PR:

Through this change, the broadcast task can collect data and send it in parallelism 1. (Before this change, the parallelism of broadcast task follows the parallelism of it's receiver.)