old_contents: from collections import Counter
  
  from redis import StrictRedis
  
  from streamparse import Bolt
  
  
  class WordCountBolt(Bolt):
      outputs = ['word', 'count']
  
      def initialize(self, conf, ctx):
          self.counter = Counter()
          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("counted %i words", self.total)
          self.emit([word, self.counter[word]])
  
  
  class RedisWordCountBolt(Bolt):
      def initialize(self, conf, ctx):
          self.redis = StrictRedis()
          self.total = 0
  
      def _increment(self, word, inc_by):
          self.total += inc_by
          return self.redis.zincrby("words", word, inc_by)
  
      def process(self, tup):
          word = tup.values[0]
          count = self._increment(word, 10 if word == "dog" else 1)
          if self.total % 1000 == 0:
              self.logger.info("counted %i words", self.total)
          self.emit([word, count])
  
new_contents: from collections import Counter
  
  from redis import StrictRedis
  
  from streamparse import Bolt
  
  
  class WordCountBolt(Bolt):
      outputs = ['word', 'count']
  
      def initialize(self, conf, ctx):
          self.counter = Counter()
          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("counted %i words", self.total)
          self.emit([word, self.counter[word]])
  
  
  class RedisWordCountBolt(Bolt):
      outputs = ['word', 'count']
  
      def initialize(self, conf, ctx):
          self.redis = StrictRedis()
          self.total = 0
  
      def _increment(self, word, inc_by):
          self.total += inc_by
          return self.redis.zincrby("words", word, inc_by)
  
      def process(self, tup):
          word = tup.values[0]
          count = self._increment(word, 10 if word == "dog" else 1)
          if self.total % 1000 == 0:
              self.logger.info("counted %i words", self.total)
          self.emit([word, count])
  
subject: Add missing outputs to wordcount_mem topology