Как использовать FieldGroupings в шторм

Question

В болтом у меня ниже записей
bolt1 -> (ID, DEPT, зарплата) Предположим, выполняемую задачу 6

Следующая болт должен получить данные, основанные на ид. может ли кто-нибудь дать мне пример кода, как использовать fieldGrouping.

Answer 1

TopologyBuilder builder = new TopologyBuilder(); 
builder.addSpout("spout" new MySpout()); 
builder.addBolt("bolt1", new Bolt1()).shuffleGrouping("spout"); // Bolt1 emits (id, dept, salary) 
builder.addBolt("bolt2", new Bolt2()).fieldsGrouping("bolt1", new Fields("id"));