在Apache Storm中，有没有一种方法可以将变量从Bolt传递到Spout？
在storm中，信息流（元组）是从喷口到螺栓的。为了防止信息过载，我在一开始对喷口处的大部分数据进行过滤，但是在处理完数据后，我想根据数据中的模式添加更多的信息通过喷口。换句话说，我想基于bolts到目前为止处理的数据，动态更改运行时从一个Spout传递的信息。
共有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")
-
我目前正在开发一个网络应用程序，它将根据许多不同的标准对社区进行评级，其中之一是来自当地警察局（爱尔兰警察局）的统计数据。在Spring中，我将一个纬度和经度值从客户端传递到控制器中，我希望运行以下SQL查询，以便找到最近的警察局并返回相关统计信息。 我试图访问的garda_station表的结构如下
-
问题内容： doIt函数将打印“ dad”。有没有办法让它打印“儿子”？ 问题答案： 是。但是就变量而言，它会被覆盖（将新值赋予变量。将新定义赋予函数是Override）。 在父类的块中使用时，该值将得到反映 如果变量是静态的，则在初始化时使用静态块更改其值， 否则更改构造函数。 你还可以稍后在任何块中更改该值。它将反映在超一流
-
我被困在一个Java编码任务中。我应该为现有程序创建三种方法（，，和），让用户将数字输入数组，然后组织并打印该数组接收数组作为参数，向用户请求索引值，并将输入的数字量返回为int。将值复制到一个新数组中，该数组的长度为返回的数字量，对数字进行排序。 我的问题是，根据作业，应该只返回输入的数字量。因此，它将打印的数组值留在方法内部，使得无法检索这些值并将其复制到第二个数组中。如果没有编辑主方法的能力
-
在C中，如果值不能为NULL，则通常引用传递而不是指针。 假设我有一个具有以下签名的函数，该签名通常与字符串文字一起使用。 我想知道如何更改函数，使其接受引用（并且具有不接受NULL的优势）？ > 另一个选项是
-
我时不时地要把一些变量从PHP传递到JS脚本。现在我是这样做的： 但这是非常难看的，而且我不能将我的JS脚本隐藏在.JS文件中，因为它必须由PHP解析。处理这个问题的最佳解决方案是什么？
-
问题内容： 在此问题中找到了我能找到的最接近的示例：https : //github.com/tensorflow/tensorflow/issues/899 使用此最小的可复制代码： 但是，返回的FLOPS始终为“无”。有没有一种方法可以具体测量FLOPS，尤其是PB文件？ 问题答案： 有点晚了，但也许将来对某些访客有帮助。对于您的示例，我成功测试了以下代码段： 也可以将分析器与以下代码段结合使