You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/05/13 22:13:01 UTC
[jira] [Commented] (STORM-789) Enhance topology context sent to
multi-lang bolts and spouts
[ https://issues.apache.org/jira/browse/STORM-789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542607#comment-14542607 ]
ASF GitHub Bot commented on STORM-789:
--------------------------------------
Github user et1975 commented on the pull request:
https://github.com/apache/storm/pull/525#issuecomment-101801046
+1 for 0.10.0 - need it now! :)
> 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
> Fix For: 0.11.0
>
>
> 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)