rheem-ecosystem / rheem

Rheem - a cross-platform data processing system
https://rheem-ecosystem.github.io
5 stars 0 forks source link

Pin down input channel instances in the execution lineage #52

Closed sekruse closed 7 years ago

sekruse commented 7 years ago

This PR offers a hotfix for issue #51 by using Rheem's reference counting facility and execution lineage to pin down input ChannelInstances of lazily executed ExecutionOperators.

In a more principled approach, however, the whole execution lineage could be subject to the reference counting scheme. Also, a test would be nice.