PROSAGA码农传奇-storm-如何从一个KafkaSpout一次发送多个（不同的）元组到螺栓？

<div class =“post-text”itemprop =“text”>
  
    喷口不能这样做，但你可以使用Storm的窗口支持
    <a href="https://storm.apache.org/releases/2.0.0-SNAPSHOT/Windowing.html" rel="nofollow noreferrer">
      https://storm.apache.org/releases/2.0.0-SNAPSHOT/Windowing.html
    </A>
    ，或者只是编写聚合螺栓并将其放在喷口和拓扑的其余部分之间。
  
  
    所以你的拓扑应该是
     <code>
 spout -> aggregator -> feature selection -> trend detection
 </code>
    。
  
  
    我建议你尝试内置的窗口支持，但如果你想编写自己的聚合，你的螺栓实际上只需要接收一些元组（例如3），并发出一个包含所有值的新元组。
  
  
    聚合器螺栓应该做类似的事情
  
   <pre>
 <code>
 private List<Tuple> buffered;

execute(Tuple input) {
 if (buffered.size != 2) {
 buffered.add(input)
 return
 }
 Tuple first = buffered.get(0)
 Tuple second = buffered.get(1)
 Values aggregate = new Values(first.getValues(), second.getValues(), input.getValues())
 List<Tuple> anchors = List.of(first, second, input)
 collector.emit(anchors, aggregate)
 collector.ack(first, second, input)
 buffered.clear()
}

</code>
 </pre>
  
    这样你最终会得到一个包含3个输入元组内容的元组。
  
</DIV>