spouttail特性storm starter及maven簡介grouping策略_第1頁
spouttail特性storm starter及maven簡介grouping策略_第2頁
spouttail特性storm starter及maven簡介grouping策略_第3頁
spouttail特性storm starter及maven簡介grouping策略_第4頁
spouttail特性storm starter及maven簡介grouping策略_第5頁
全文預覽已結束

下載本文檔

版權說明：本文檔由用戶提供并上傳，收益歸屬內容提供方，若內容存在侵權，請進行舉報或認領

文檔簡介

Storm流計算從入門到精通—技術篇講師：Cloudy（北風網版權所有)6、Spout的tail特性、storm-starter及maven簡介Spout的tail特性Tail適合文本源如果是MessageQueue源的話，該特性沒必要。Storm-starter官方提供的例子包最好的學習資料/nathanmarz/storm-starter

下載地址Maven：打包程序，比ant強大mvneclipse:eclipseFatjareclipse插件，特點：慢，而且只能設一個main類streamgrouping就是用來定義一個stream應該如果分配給Bolts上面的多個Tasks。storm里面有6種類型的streamgrouping:1.ShuffleGrouping:隨機分組，隨機派發stream里面的tuple，保證每個bolt接收到的tuple數目相同。輪詢，平均分配。2.FieldsGrouping：按字段分組，比如按userid來分組，具有同樣userid的tuple會被分到相同的Bolts，而不同的userid則會被分配到不同的Bolts。3.AllGrouping：廣播發送，對于每一個tuple，所有的Bolts都會收到。4.GlobalGrouping:全局分組，這個tuple被分配到storm中的一個bolt的其中一個task。再具體一點就是分配給id值最低的那個task。5.NonGrouping:不分組，這個分組的意思是說stream不關心到底誰會收到它的tuple。目前這種分組和Shufflegrouping是一樣的效果，不平均分配。6.DirectGrouping:直接分組，這是一種比較特別的分組方法，用這種分組意味著消息的發送者舉鼎由消息接收者的哪個task處理這個消息。只有被聲明為DirectStream的消息流可以聲明這種分組方法。而且這種消息tuple必須使用emitDirect方法來發射。消息處理者可以通過TopologyContext來或者處理它的消息的ta

溫馨提示

  • 1. 本站所有資源如無特殊說明，都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
  • 2. 本站的文檔不包含任何第三方提供的附件圖紙等，如果需要附件，請聯系上傳者。文件的所有權益歸上傳用戶所有。
  • 3. 本站RAR壓縮包中若帶圖紙，網頁內容里面會有圖紙預覽，若沒有圖紙預覽就沒有圖紙。
  • 4. 未經權益所有人同意不得將文件中的內容挪作商業或盈利用途。
  • 5. 人人文庫網僅提供信息存儲空間，僅對用戶上傳內容的表現方式做保護處理，對用戶上傳分享的文檔內容本身不做任何修改或編輯，并不能對任何下載內容負責。
  • 6. 下載文件中如有侵權或不適當內容，請與我們聯系，我們立即糾正。
  • 7. 本站不保證下載資源的準確性、安全性和完整性, 同時也不承擔用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。

評論

0/150

提交評論