From e3d2ffca585660f0c088ab8323bfe78a86ba75e3 Mon Sep 17 00:00:00 2001
From: Cody Hiar <cody@hiar.ca>
Date: Mon, 25 Oct 2021 14:34:37 -0600
Subject: Save working version of deploying jars

---
 wordcount/multilang/resources/sentencespout.py | 28 ++++++++++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 wordcount/multilang/resources/sentencespout.py

(limited to 'wordcount/multilang/resources/sentencespout.py')

diff --git a/wordcount/multilang/resources/sentencespout.py b/wordcount/multilang/resources/sentencespout.py
new file mode 100644
index 0000000..a75f37d
--- /dev/null
+++ b/wordcount/multilang/resources/sentencespout.py
@@ -0,0 +1,28 @@
+import storm
+import random
+# Define some sentences
+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
+""".strip().split('\n')
+
+class SentenceSpout(storm.Spout):
+    # Not much to do here for such a basic spout
+    def initialize(self, conf, context):
+        self._conf = conf
+        self._context = context
+
+        storm.logInfo("Spout instance starting...")
+
+    # Process the next tuple
+    def nextTuple(self):
+        # Emit a random sentence
+        sentence = random.choice(SENTENCES)
+        storm.logInfo("Emiting %s" % sentence)
+        storm.emit([sentence])
+
+# Start the spout when it's invoked
+SentenceSpout().run()
-- 
cgit v1.2.3