[
https://issues.apache.org/jira/browse/SAMZA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari reassigned SAMZA-1745:
-----------------------------------------
Assignee: Prateek Maheshwari
> 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
> Assignee: Prateek Maheshwari
> Priority: Major
>
> 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)
