1. 程式人生 > >Storm理論知識之filed

Storm理論知識之filed


對Filed欄位的理解。(相當於資料庫表的欄位名稱)
1、設定兩列資料的列名:declarer.declare(new Fields("species"),("con"));
2、emit提交的資料 new values("水果","西瓜")、new values("水果","蘋果")、new values("生活用品","紙巾");
3、後面的bolt接收資料,input.getString(0)/input.getString(1)  or input.getStringByField("species")/input.getStringByField("con");


使用方法:

fieldsGrouping("bolt_id", new Fields("species")) 可以使欄位species相同的值,傳送到同一個bolt中進行處理。


例子如下:
spout傳送了資料 如:new values("水果","西瓜")
fieldsGrouping("bolt_id", new Fields("species")) 


bolt-Thread-1接收
        Filed species  con
               水果    西瓜
               水果    蘋果
                ...  ...


bolt-Thread-2接收
        Filed species      con
               生活用品    紙巾
               蔬菜        西紅柿
                ...  ...