在Apache Storm中，有没有一种方法可以将变量从Bolt传递到Spout？

Question

在storm中，信息流（元组）是从喷口到螺栓的。为了防止信息过载，我在一开始对喷口处的大部分数据进行过滤，但是在处理完数据后，我想根据数据中的模式添加更多的信息通过喷口。换句话说，我想基于bolts到目前为止处理的数据，动态更改运行时从一个Spout传递的信息。

Answer 1

不是。但是你可以把过滤逻辑从喷口移到新的第一个螺栓中。喷口只是获取所有数据并将其转发到新的过滤器螺栓。对于螺栓，可以在图中有循环，即，您可以将信息反馈到过滤器螺栓。例如如下所示：

builder.addSpout("spout",...);
builder.addBolt("filter",...)
  .localOrShuffleGrouping("spout") // regular forward connection
  .allGrouping("someLaterBolt"); // cyclic feedback connection 
// add more bolts here
builder.addBolt("someLaterBolt",...).someConnectionPattern("somePreviousBolt")