colinsurprenant/redstorm

View on GitHub
examples/shell/resources/splitsentence.py

Summary

Maintainability
A
0 mins
Test Coverage
import storm

class SplitSentenceBolt(storm.BasicBolt):
    def process(self, tup):
        words = tup.values[0].split(" ")
        for word in words:
          storm.emit([word])

SplitSentenceBolt().run()