Matthias J. Sax created FLINK-2306:
--------------------------------------
Summary: 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
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)
