Gyula Fora created FLINK-2279:
---------------------------------
Summary: Allow treating iteration head as ConnectedDataStream
Key: FLINK-2279
URL: https://issues.apache.org/jira/browse/FLINK-2279
Project: Flink
Issue Type: New Feature
Components: Streaming
Affects Versions: 0.10
Reporter: Gyula Fora
Assignee: Gyula Fora
Priority: Minor
Currently the streaming iterations are restricted to use the same input and
feedback types which are routed through the same operator.
This means that if the user want to distinguish between normal input and
feedback record he/she needs to mark it somehow and also a wrapper type is
necessary for handling separate input and feedback types.
This makes implementing iterative algorithms (such as ML) quite ugly at some
points.
I propose to let the user treat the normal input if the iteration head operator
and the feedback input as a ConnectedDataStream which can be used to apply
co-operators both distinguishing the inputs and allowing different feedback
types for elegant implementations.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
