You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Dan Blanchard (JIRA)" <ji...@apache.org> on 2015/04/16 22:28:58 UTC
[jira] [Created] (STORM-789) Enhance topology context sent to
multi-lang bolts and spouts
Dan Blanchard created STORM-789:
-----------------------------------
Summary: Enhance topology context sent to multi-lang bolts and spouts
Key: STORM-789
URL: https://issues.apache.org/jira/browse/STORM-789
Project: Apache Storm
Issue Type: Improvement
Reporter: Dan Blanchard
Assignee: Dan Blanchard
I'm about to submit a pull request that adds a lot more contextual information to the "context" JSON dictionary that gets sent to multi-lang bolts and spouts as part of their initial handshake. These additions will make is so non-JVM developers have access to the sources, targets, and field names for their bolts and spouts.
We will add support for this in streamparse (one of the more popular Python libraries for Storm) as soon as this gets merged in.
Here are the details of what I've added:
- 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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)