[ https://issues.apache.org/jira/browse/SAMZA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yi Pan (Data Infrastructure) reassigned SAMZA-1101: --------------------------------------------------- Assignee: Yi Pan (Data Infrastructure) > Delay the creation of actual function to send to a physical stream until > OperatorImpl instantiation > --------------------------------------------------------------------------------------------------- > > Key: SAMZA-1101 > URL: https://issues.apache.org/jira/browse/SAMZA-1101 > Project: Samza > Issue Type: Bug > Reporter: Yi Pan (Data Infrastructure) > Assignee: Yi Pan (Data Infrastructure) > Labels: fluent-api > > There are a few reasons for that: > # it helps to keep the logic StreamGraphImpl only refers to logic stream > (i.e. the physical stream properties should be populated by physical > ExecutionEnvironment) > # it helps to keep the OperatorSpec for sendTo() only containing spec info, > not physical implementation, which allows us to swap in collection-based or > file-based streams sendTo() function w/o the user program change -- This message was sent by Atlassian JIRA (v6.3.15#6346)