Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.12.0
-
None
Description
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
Attachments
Issue Links
- Is contained by
-
SAMZA-1221 Simplify MessageStreamImpl and OperatorSpec graphs and traversals
- Resolved