[ 
https://issues.apache.org/jira/browse/SAMZA-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Prateek Maheshwari resolved SAMZA-1745.
---------------------------------------
    Resolution: Fixed

> 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)

Reply via email to