You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/13 09:50:45 UTC
[jira] [Commented] (FLINK-2306) Add support for named streams in
Storm compatibility layer
[ https://issues.apache.org/jira/browse/FLINK-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14694850#comment-14694850 ]
ASF GitHub Bot commented on FLINK-2306:
---------------------------------------
GitHub user mjsax opened a pull request:
https://github.com/apache/flink/pull/1011
[FLINK-2306] Add support for named streams in Storm compatibility layer
- enabled .declareStream() and connect via stream name
- enabled multiplt output streams
- added .split() / .select() / strip pattern
- added helpers in new package utils
- adapted and extended JUnit tests
- adapted examples
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/flink flink-2306-storm-namedStreams
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1011.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1011
----
commit 0b7f47fed18fbe9c9b353960b337e2d8454e11b7
Author: mjsax <mj...@informatik.hu-berlin.de>
Date: 2015-08-13T06:56:47Z
[FLINK-2306] Add support for named streams in Storm compatibility layer
- enabled .declareStream() and connect via stream name
- enabled multiplt output streams
- added .split() / .select() / strip pattern
- added helpers in new package utils
- adapted and extended JUnit tests
- adapted examples
some minor improvements (FlinkClient, integration of Tuple0)
commit c48ad0f516ee7583f8a6c4e564213fcd614c74e2
Author: mjsax <mj...@informatik.hu-berlin.de>
Date: 2015-08-12T18:56:58Z
Added split examples
- example for embedded Spout/Bolt
- two test-examples for complete topologies
Additionally:
- updated README.md
- extended web documentation
- add comments to pom.xml to explain examples better
commit 71eeb4f2b77b643e0bbc0af4ed9fe212a4a306b7
Author: mjsax <mj...@informatik.hu-berlin.de>
Date: 2015-08-12T18:57:21Z
TO BE DELETED
- this PR depends on FLINK-2457 (Integrate Tuple0), ie, PR #983
- this changes are hotfixes to make the branch work and are not needed after PR#983 is merged and this branch is rebased
----
> 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)