Как изменить баланс Сторм Trident Топология

Question

От this ссылки документации я мог бы узнать, что изменение баланса топологии легко с ниже команд

storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10 

Но как я заново балансировать топологию трезубца как в трезубце топологии мы не можем маркировать фильтры/функции (болты) с именем, так как я могу увеличить/уменьшить количество параллелизма? Или есть способ увеличить/уменьшить количество параллелизма с использованием множителя для всех компонентов в конкретной топологии?

Answer 1

Позвольте мне ответить на мои вопросы;

В случае желобов и болтов Trident автоматически присваиваются имена и имена b-0, b-1, b-2. Это означает Blot-1 и Bolt-2. Это имя можно узнать в пользовательском интерфейсе Storm для развернутой топологии

Теперь, используя эти имена болтов, мы можем перебалансировать развернутую топологию.

storm rebalance mytopology -n 5 -e b-0=3 -e b-1=10 

ПРИМЕЧАНИЕ: Можно также назвать болт при создании Trident топологии

например;

topology.newStream("spout", spout) 
     .each(new Fields("sentence"), new Split(), new Fields("word")) 
     .shuffle() 
     .name("BOLT-NAME")