阿帕奇风暴螺栓

Question

class MyBolt(storm.BasicBolt):
    def process(self, tup):
        data = tup.values[0].split(',')

我是Apache Storm的新手，看到上面的程序但不是很明白。我想知道 data=tup.values[0] 做什么。感谢您的帮助！

Answer 1

根据定义，元组是对象的有序列表。 tup.values[0] 按位置 从元组 中检索对象。所以它只是 returns 元组中的第一个对象。