GitHub user Darkless012 opened a pull request:
https://github.com/apache/storm/pull/1426
FluxShellBolt/FluxShellSpout can now emit into named streams + YAML DSL
example
I need ability for FluxShellBolt/FluxShellSpout to emit into named streams.
This pull request maintains backward compatibility, while adding 2 new
methods to set stream output.
In Flux YAML DLS the named streams can be created either the old way
(default stream only) or by using the new methods:
```
bolts:
- className: org.apache.storm.flux.wrappers.bolts.FluxShellBolt
id: my_bolt
constructorArgs:
- [python, my_bolt.py]
configMethods:
- name: setNamedStream
args:
- first
- [word, count]
```
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Darkless012/storm master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1426.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 #1426
----
commit 25dd41ed1e03a02aeb82bea7bc7e3f11da3867a6
Author: Pavel Grochal <[email protected]>
Date: 2016-05-17T13:11:29Z
FluxShellBolt can emit into custom stream.
commit 8a175701fa797d4bb4c90814e49f7dbac287caa3
Author: Pavel Grochal <[email protected]>
Date: 2016-05-17T13:12:13Z
Fixed imports
commit d97cab9118268b2af51cec77ae31ca6dc2a62220
Author: Pavel Grochal <[email protected]>
Date: 2016-05-17T13:17:50Z
FluxShellSpout can emit into streams.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
