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

Stephan Ewen closed FLINK-2306.
-------------------------------

> Add support for named streams in Storm compatibility layer
> ----------------------------------------------------------
>
>                 Key: FLINK-2306
>                 URL: https://issues.apache.org/jira/browse/FLINK-2306
>             Project: Flink
>          Issue Type: Improvement
>          Components: flink-contrib
>            Reporter: Matthias J. Sax
>            Assignee: Matthias J. Sax
>             Fix For: 0.10
>
>
> Currently, the layer only works on single stream and ignores stream names, 
> ie, each stream is treated as "default" stream. The declaration of multiple 
> output streams is ignored (all tuples are emitted to the same stream). If 
> multiple input streams are consumed all tuples are merged into a single 
> stream.
> This feature allows operators to declare multiple (named) output streams and 
> emit tuples to different stream. Furthermore, it enables Bolts to distinguish 
> incoming tuples from different streams by stream name (Storm tuple meta 
> information).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to