diff options
| author | Cody Hiar <cody@hiar.ca> | 2021-10-25 14:34:37 -0600 |
|---|---|---|
| committer | Cody Hiar <cody@hiar.ca> | 2021-10-25 14:34:37 -0600 |
| commit | e3d2ffca585660f0c088ab8323bfe78a86ba75e3 (patch) | |
| tree | 1f542c4d1c032cdc85149ccfd28cafc402ddb3d0 /wordcount/topologies/wordcount.py | |
| parent | 08cf73a70e3ce2dbc85e8b389f15090c148ec003 (diff) | |
Save working version of deploying jars
Diffstat (limited to 'wordcount/topologies/wordcount.py')
| -rw-r--r-- | wordcount/topologies/wordcount.py | 13 |
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) |