storm-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anya Tchernishov (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (STORM-386) Development of multilang protocol in nodejs
Date Thu, 03 Jul 2014 15:10:25 GMT

    [ https://issues.apache.org/jira/browse/STORM-386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14051555#comment-14051555
] 

Anya Tchernishov commented on STORM-386:
----------------------------------------

Pull request https://github.com/apache/incubator-storm/pull/177

> Development of multilang protocol in nodejs
> -------------------------------------------
>
>                 Key: STORM-386
>                 URL: https://issues.apache.org/jira/browse/STORM-386
>             Project: Apache Storm (Incubating)
>          Issue Type: New Feature
>         Environment: nodejs
>            Reporter: Anya Tchernishov
>
> 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.2#6252)

Mime
View raw message