Storm 拓扑可以包含循环吗?
Can Storm topologies contain cycles?
我最近一直在阅读有关 Apache Storm 的论文。据我了解,它基于操作和数据流的有向无环图。
然而,在 Storm@Twitter 中它说:
Note that a Storm topology can have cycles.
如何应用于DAG的定义?
Storm 不会阻止您在拓扑中创建循环。示例:
builder.setSpout("word", new TestWordSpout(), 10);
builder.setBolt("exclaim1", new ExclamationBolt(), 3)
.shuffleGrouping("word")
.shuffleGrouping("exclaim2");
builder.setBolt("exclaim2", new ExclamationBolt(), 2).shuffleGrouping("exclaim1");
另见 https://groups.google.com/forum/#!topic/storm-user/EjN1hU58Q_8。循环似乎不是一个好主意,如果它们被普遍使用我会感到惊讶。
我最近一直在阅读有关 Apache Storm 的论文。据我了解,它基于操作和数据流的有向无环图。
然而,在 Storm@Twitter 中它说:
Note that a Storm topology can have cycles.
如何应用于DAG的定义?
Storm 不会阻止您在拓扑中创建循环。示例:
builder.setSpout("word", new TestWordSpout(), 10);
builder.setBolt("exclaim1", new ExclamationBolt(), 3)
.shuffleGrouping("word")
.shuffleGrouping("exclaim2");
builder.setBolt("exclaim2", new ExclamationBolt(), 2).shuffleGrouping("exclaim1");
另见 https://groups.google.com/forum/#!topic/storm-user/EjN1hU58Q_8。循环似乎不是一个好主意,如果它们被普遍使用我会感到惊讶。