Могут ли топологии Storm содержать циклы?
Я недавно читал статьи об Apache Storm. Из того, что я понял, это основано на Направленном ациклическом графе операций и потоков данных.
Однако в Storm@Twitter написано:
Обратите внимание, что топология Storm может иметь циклы.
Как это относится к определению DAG?
1 ответ
Решение
Шторм не мешает вам совершать циклы в вашей топологии. Пример:
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/. Циклы не кажутся хорошей идеей, и я бы удивился, если бы они широко использовались.