Prateek Maheshwari created SAMZA-1745:
-----------------------------------------
Summary: Remove usages of StreamSpec and ApplicationRunner from
the OperatorSpec and OperatorImpl layers.
Key: SAMZA-1745
URL: https://issues.apache.org/jira/browse/SAMZA-1745
Project: Samza
Issue Type: Improvement
Reporter: Prateek Maheshwari
Removes all usages of StreamSpec and ApplicationRunner from the OperatorSpec
and OperatorImpl layers. DAG specification (StreamGraphSpec, OperatorSpecs)
should only relies on logical streamIds (and in future, will use the
user-provided StreamDescriptors). DAG execution (i.e., StreamOperatorTask,
OperatorImpls) should only relies on logical streamIds and their corresponding
SystemStreams, which can be obtained using StreamConfig in OperatorImplGraph.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
