You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by "Rick Kellogg (JIRA)" <ji...@apache.org> on 2015/10/05 04:06:27 UTC
[jira] [Updated] (STORM-386) Development of multilang protocol in
nodejs
[ https://issues.apache.org/jira/browse/STORM-386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rick Kellogg updated STORM-386:
-------------------------------
Component/s: storm-multilang
> Development of multilang protocol in nodejs
> -------------------------------------------
>
> Key: STORM-386
> URL: https://issues.apache.org/jira/browse/STORM-386
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-multilang
> Environment: nodejs
> Reporter: Anya Tchernishov
> Assignee: Itai Frenkel
> Fix For: 0.9.3
>
>
> Support nodejs multilang protocol.
> Design considerations:
> - Emit will receive an object (like args and kwargs in python) and a callback that is called when task ids list is received.
> self.emit({tuple: [word]}, function(taskIds) {
> self.log(word + ' sent to task ids - ' + taskIds);
> });
> - The following methods will received done method that must be invoked on completion (same pattern used by the mocha test framework for async unit tests).
> - Internal implementation of emit uses Process.stdout.write without a callback since nodejs streams maintain FIFO order (so far, we have not found a need for providing a callback).
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)