Storm理論知識之filed
阿新 • • 發佈:2018-11-11
對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
生活用品 紙巾
蔬菜 西紅柿
... ...