Node multilang protocol implementation

examples/storm-starter/multilang/resources/asyncSplitsentence.js

@@ -0,0 +1,33 @@
+/**
+ * Example for async bolt. Receives sentence and breaks it into words.
+ *
+ * Created by anya on 6/30/14.
+ */
+
+
+var storm = require('./storm');
+var BasicBolt = storm.BasicBolt;
+
+function SplitSentenceBolt() {
+    BasicBolt.call(this);
+};
+
+SplitSentenceBolt.prototype = Object.create(BasicBolt.prototype);
+SplitSentenceBolt.prototype.constructor = SplitSentenceBolt;
+
+SplitSentenceBolt.prototype.process = function(tup, done) {
+    var self = this;
+
+    // Here setTimeout is not really needed, we use it to demonstrate asynchronous code in the process method:
+    setTimeout(function() {
+        var words = tup.values[0].split(" ");
+        words.forEach(function(word) {
+            self.emit({tuple: [word], anchorTupleId: tup.id}, function(taskIds) {
+                self.log(word + ' sent to task ids - ' + taskIds);
+            });
+        });
+        done();
+    }, 5000)
+}
+
+new SplitSentenceBolt().run();

examples/storm-starter/multilang/resources/randomsentence.js

@@ -0,0 +1,72 @@
+/**
+ * Example for storm spout. Emits random sentences.
+ * The original class in java - storm.starter.spout.RandomSentenceSpout.
+ *
+ * Created by anya on 6/26/14.
+ */
+
+var storm = require('./storm');
+var Spout = storm.Spout;
+
+
+var SENTENCES = [
+    "the cow jumped over the moon",
+    "an apple a day keeps the doctor away",
+    "four score and seven years ago",
+    "snow white and the seven dwarfs",
+    "i am at two with nature"]
+
+function RandomSentenceSpout(sentences) {
+    Spout.call(this);
+    this.runningTupleId = 0;
+    this.sentences = sentences;
+    this.pending = {};
+};
+
+RandomSentenceSpout.prototype = Object.create(Spout.prototype);
+RandomSentenceSpout.prototype.constructor = RandomSentenceSpout;
+
+RandomSentenceSpout.prototype.getRandomSentence = function() {
+    return this.sentences[getRandomInt(0, this.sentences.length - 1)];
+}
+
+RandomSentenceSpout.prototype.nextTuple = function(done) {
+    var self = this;
+    var sentence = this.getRandomSentence();
+    var tup = [sentence];
+    var id = this.createNextTupleId();
+    this.pending[id] = tup;
+    this.emit({tuple: tup, id: id}, function(taskIds) {
+        self.log(tup + ' sent to task ids - ' + taskIds);
+    });
+    done();
+}
+
+RandomSentenceSpout.prototype.createNextTupleId = function() {
+    var id = this.runningTupleId;
+    this.runningTupleId++;
+    return id;
+}
+
+RandomSentenceSpout.prototype.ack = function(id, done) {
+    this.log('Received ack for - ' + id);
+    delete this.pending[id];
+    done();
+}
+
+RandomSentenceSpout.prototype.fail = function(id, done) {
+    this.log('Received fail for - ' + id + '. Retrying.');
+    this.emit({tuple: this.pending[id], id:id}, function(taskIds) {
+        self.log(this.pending[id] + ' sent to task ids - ' + taskIds);
+    });
+    done();
+}
+
+/**
+ * Returns a random integer between min (inclusive) and max (inclusive)
+ */
+function getRandomInt(min, max) {
+    return Math.floor(Math.random() * (max - min + 1)) + min;
+}
+
+new RandomSentenceSpout(SENTENCES).run();

examples/storm-starter/multilang/resources/splitsentence.js

@@ -0,0 +1,26 @@
+/**
+ * Bolt example - receives sentence and breaks it into words.
+ */
+
+var storm = require('./storm');
+var BasicBolt = storm.BasicBolt;
+
+function SplitSentenceBolt() {
+    BasicBolt.call(this);
+};
+
+SplitSentenceBolt.prototype = Object.create(BasicBolt.prototype);
+SplitSentenceBolt.prototype.constructor = SplitSentenceBolt;
+
+SplitSentenceBolt.prototype.process = function(tup, done) {
+        var self = this;
+        var words = tup.values[0].split(" ");
+        words.forEach(function(word) {
+            self.emit({tuple: [word], anchorTupleId: tup.id}, function(taskIds) {
+                self.log(word + ' sent to task ids - ' + taskIds);
+            });
+        });
+        done();
+}
+
+new SplitSentenceBolt().run();