flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2306) Add support for named streams in Storm compatibility layer
Date Wed, 01 Jul 2015 09:39:05 GMT
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

View raw message