aboutsummaryrefslogtreecommitdiff
path: root/wordcount/topologies
diff options
context:
space:
mode:
authorCody Hiar <cody@hiar.ca>2021-10-25 14:34:37 -0600
committerCody Hiar <cody@hiar.ca>2021-10-25 14:34:37 -0600
commite3d2ffca585660f0c088ab8323bfe78a86ba75e3 (patch)
tree1f542c4d1c032cdc85149ccfd28cafc402ddb3d0 /wordcount/topologies
parent08cf73a70e3ce2dbc85e8b389f15090c148ec003 (diff)
Save working version of deploying jars
Diffstat (limited to 'wordcount/topologies')
-rw-r--r--wordcount/topologies/wordcount.py13
1 files changed, 0 insertions, 13 deletions
diff --git a/wordcount/topologies/wordcount.py b/wordcount/topologies/wordcount.py
deleted file mode 100644
index d66e1b3..0000000
--- a/wordcount/topologies/wordcount.py
+++ /dev/null
@@ -1,13 +0,0 @@
-"""
-Word count topology
-"""
-
-from streamparse import Grouping, Topology
-
-from bolts.wordcount import WordCountBolt
-from spouts.words import WordSpout
-
-
-class WordCount(Topology):
- word_spout = WordSpout.spec()
- count_bolt = WordCountBolt.spec(inputs={word_spout: Grouping.fields("word")}, par=2)