我有以下问题。我有一个apache storm拓扑，它看起来像这样：a->b->ca:是一个喷口，从数据库里得到了一些序列b:正在分裂这个序列并发射n个长序列c:计算子序列是否在所有序列中现在，如果c发现一个子序列不在所有序列中，它应该向b发送一条指令消息，说明b可以删减一些序列，并且不能发送比不在所有列表中的子序列长的所有元组。我的问题是如何在b的消息队列中转发这个指令元组。
pdsfdshx1#
您可以简单地定义循环图：
TopologyBuilder builder = new TopologyBuilder(); builder.addSpout("A",...); builder.addBolt("B",...) .someConnectionPattern("A") // regular forward connection .allGrouping("C"); // cyclic feedback connection builder.addBolt("C",...).someConnectionPattern("B")
在这个例子中，我使用 allGrouping 将截断信息分发给所有示例。根据您的用例 fieldsGrouping 可能也有用。
allGrouping
fieldsGrouping
1条答案
按热度按时间pdsfdshx1#
您可以简单地定义循环图：
在这个例子中，我使用
allGrouping将截断信息分发给所有示例。根据您的用例fieldsGrouping可能也有用。