storm-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (STORM-386) Development of multilang protocol in nodejs
Date Thu, 24 Jul 2014 07:45:38 GMT

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

ASF GitHub Bot commented on STORM-386:
--------------------------------------

Github user itaifrenkel commented on the pull request:

    https://github.com/apache/incubator-storm/pull/177#issuecomment-49976975
  
    The JIRA is STORM-386 as mentioned in the description (will fix the title once the developer
is back in the office). We are using it in production already to migrate nodejs code to storm
(low throughput low latency application).


> 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