как я могу получить источник данных болта?

Я новичок в штормовой среде, и у меня есть вопрос! У меня есть 2 носика (spoutA и spoutB), которые передают данные болту (bolt1). Я определил этот болт следующим образом:

builder.setBolt("bolt1", bolt1).shuffleGrouping("spoutA").shuffleGrouping("spoutB");

Есть ли способ в Bolt1 узнать для каждого полученного кортежа, каков его источник (spoutA или spoutB)?


apache-storm
person Pietro    schedule 11.09.2014    source источник

Ответы (1)


arrow_upward
1
arrow_downward

с официальной страницы документа

Если вы реализуете болт, который подписывается на несколько источников ввода, вы можете узнать, из какого компонента получен кортеж, используя метод Tuple#getSourceComponent.

person user2720864    schedule 11.09.2014