Prateek Maheshwari created SAMZA-1221: -----------------------------------------
Summary: Simplify MessageStreamImpl and OperatorSpec graphs and traversals Key: SAMZA-1221 URL: https://issues.apache.org/jira/browse/SAMZA-1221 Project: Samza Issue Type: Bug Reporter: Prateek Maheshwari Fix For: 0.13.0 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. -- This message was sent by Atlassian JIRA (v6.3.15#6346)