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/src/spouts/__init__.py |  0
 wordcount/src/spouts/words.py    | 14 --------------
 2 files changed, 14 deletions(-)
 delete mode 100644 wordcount/src/spouts/__init__.py
 delete mode 100644 wordcount/src/spouts/words.py

(limited to 'wordcount/src/spouts')

diff --git a/wordcount/src/spouts/__init__.py b/wordcount/src/spouts/__init__.py
deleted file mode 100644
index e69de29..0000000
diff --git a/wordcount/src/spouts/words.py b/wordcount/src/spouts/words.py
deleted file mode 100644
index 6ba88c1..0000000
--- a/wordcount/src/spouts/words.py
+++ /dev/null
@@ -1,14 +0,0 @@
-from itertools import cycle
-
-from streamparse import Spout
-
-
-class WordSpout(Spout):
-    outputs = ["word"]
-
-    def initialize(self, stormconf, context):
-        self.words = cycle(["dog", "cat", "zebra", "elephant"])
-
-    def next_tuple(self):
-        word = next(self.words)
-        self.emit([word])
-- 
cgit v1.2.3