GitHub user dan-blanchard opened a pull request:
https://github.com/apache/storm/pull/525
Send more topology context to Multi-Lang components via initial handshake
This PR adds the following keys to the "context" JSON dictionary sent to
multi-lang tasks as part of their handshake with ShellBolt/ShellSpout:
- `componentid`: the component ID for this task, so you no longer have to
look it up in `task->component` by `taskid`
- `streams`: a list of all of the streams for this task
- `stream->outputfields`: a mapping from stream names to output fields
for that stream
- `stream->target->grouping`: a mapping from stream names to the targets
for this task to the kind of grouping they use.
- `sources->grouping`: a mapping from the component IDs of the sources to
their grouping.
Note on groupings: groupings are either represented as a string (e.g.,
"SHUFFLE") or a list of strings for field groupings.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dan-blanchard/incubator-storm STORM-789
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/525.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 #525
----
commit 174e1a05759ef3722670f7709311d58862bcf483
Author: Dan Blanchard <[email protected]>
Date: 2015-04-16T20:15:32Z
Send more topology context to Multi-Lang components via initial handshake.
This commit adds the following keys to the "context" JSON dictionary sent to
multi-lang tasks as part of their handshake with ShellBolt/ShellSpout:
- componentid: the component ID for this task, so you don't have to look
it up
in "task->component" by "taskid"
- streams: a list of all of the streams for this task
- stream->outputfields: a mapping from stream names to output fields for
that
stream
- stream->target->grouping: a mapping from stream names to the targets for
this
task to the kind of grouping they use.
- sources->grouping: a mapping from the component IDs of the sources to
their
grouping.
Note on groupings: groupings are either represented as a string (e.g., "
SHUFFLE") or a list of strings for field groupings.
----
---
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.
---
