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)