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

(limited to 'wordcount/src/bolts')

diff --git a/wordcount/src/bolts/__init__.py b/wordcount/src/bolts/__init__.py
deleted file mode 100644
index e69de29..0000000
diff --git a/wordcount/src/bolts/wordcount.py b/wordcount/src/bolts/wordcount.py
deleted file mode 100644
index 85fbfb7..0000000
--- a/wordcount/src/bolts/wordcount.py
+++ /dev/null
@@ -1,26 +0,0 @@
-import os
-from collections import Counter
-
-from streamparse import Bolt
-
-
-class WordCountBolt(Bolt):
-    outputs = ["word", "count"]
-
-    def initialize(self, conf, ctx):
-        self.counter = Counter()
-        self.pid = os.getpid()
-        self.total = 0
-
-    def _increment(self, word, inc_by):
-        self.counter[word] += inc_by
-        self.total += inc_by
-
-    def process(self, tup):
-        word = tup.values[0]
-        self._increment(word, 10 if word == "dog" else 1)
-        if self.total % 1000 == 0:
-            self.logger.info(
-                f"counted [{self.total:,}] words [pid={self.pid}]"
-            )
-        self.emit([word, self.counter[word]])
-- 
cgit v1.2.3