Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Currently the logical operator DAG traversal is unnecessarily convoluted since it requires interacting with both MessageStreamImpls (which provides #getRegisteredOperatorSpecs) and OperatorSpecs (which provides #getNextStream). This would be cleaner if we separated these two graphs such that the framework tracks and interacts only with the OperatorSpecs graph, and the MessageStreamImpl graph is just a user-facing view of it.
Attachments
Issue Links
- contains
-
SAMZA-1101 Delay the creation of actual function to send to a physical stream until OperatorImpl instantiation
- Resolved
- links to