

def process_tuple(self, tup):
    (line,) = self.values
    log.debug(line)
    for word in line.split():
        log.debug(word)
        self.emit((word,), anchors=[tup])

dataset/ETHPy150Open Yelp/pyleus/examples/word_count/word_count/split_words.py SplitWordsBolt.process_tuple/VarMisuse@17/19 `tup`->`self`