2013-10-16 233 views
3

在我的Storm拓撲中,我將大程序邏輯保存在一個螺栓中。現在我將大的程序邏輯分成線性排列的小螺栓。它的表現有什麼不同嗎?在Storm拓撲中用線性螺栓替換單個螺栓的區別

+0

這取決於您添加的設備的數量。你檢查過性能嗎? – Hariharan

+0

它可以運行得更快,也可以運行得更慢,具體取決於原始和生成螺栓的粒度。規則是,避免做少量工作的螺栓,執行時間應至少爲1毫秒。 –

+0

這是一個真正的「它取決於」的情況。也許你可以用關於這個任務的更多細節來充實你的問題? – lorcan

回答

0

根據您的評論描述:

在我的拓撲中,我創建詞的字典。我有一個噴嘴和兩個螺栓。 Spout將讀取一段文字,並將每行作爲消息發送給第一個螺栓。第一螺栓將分割每條線成單詞和發射具有兩個字段的消息(字和它的第一個字符),第二螺栓從第一螺栓接收消息,並根據字存儲該單詞的起始字符在相應的數據庫

我會說這是一個很好的多螺栓場景。我(試圖)在下面繪製一個樸素的拓撲。分詞螺栓這個詞讀取一個段落,並將該字/字符對發送到計數器螺栓(按字組分組)。計數器可以自己處理持久性,或者交給另一個執行持久性的螺栓(這裏沒有繪製)。

     /B (counter) 
/B (word splitter)/B (counter) 
S ...     ... 
    \ B (word splitter) \ B (counter) 
         \ B (counter) 

你可能會考慮在三叉戟寫這個,而不是用螺栓,尤其是在活動由螺栓進行(至少在這裏)是非常簡單的。