storm-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anya Tchernishov (JIRA)" <>
Subject [jira] [Created] (STORM-386) Development of multilang protocol in nodejs
Date Thu, 03 Jul 2014 15:08:24 GMT
Anya Tchernishov created STORM-386:

             Summary: Development of multilang protocol in nodejs
                 Key: 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

View raw message