볼트 폭풍

Question

에 FieldGroupings를 사용하는 방법은 기록 아래
bolt1 있습니다. 누구든지 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"));