-
安裝maven,將maven加入bin目錄中,測(cè)試是否可以使用查看全部
-
storm ui時(shí)storm提供頁面查看和管理的查看全部
-
完成一個(gè)分布式的rpc服務(wù),只有用戶使用rpc時(shí)用,一般情況下并不需要查看全部
-
加了個(gè)中間層進(jìn)行管理查看全部
-
真正進(jìn)行數(shù)據(jù)計(jì)算和傳輸?shù)亩际怯欣锩娴膚order進(jìn)行查看全部
-
聽nimbus的話,但他也不進(jìn)行數(shù)據(jù)的計(jì)算和傳輸查看全部
-
單點(diǎn)上,無狀態(tài),重啟后就可以運(yùn)行,只是一些管理的工作,如果當(dāng)?shù)簦渌臄?shù)據(jù)還會(huì)正常運(yùn)行查看全部
-
strom 開源的分布式的流式系統(tǒng)查看全部
-
apache strorm 開源 分布式 流式系統(tǒng)查看全部
-
批量計(jì)算和流式計(jì)算對(duì)比查看全部
-
Google分布式計(jì)算的三個(gè)基礎(chǔ)查看全部
-
一臺(tái)機(jī)器 三年出一次故障 1000臺(tái)機(jī)器 每天出故障的概率 1 - 0.999^1000 = 63.2% 故障處理 Nimbus故障,換臺(tái)機(jī)器重啟即可 Supervisor掛掉,遷移其上Worker即可 worker掛掉 數(shù)據(jù)丟失 處理超時(shí) Spout數(shù)據(jù)保障 不丟:Acker機(jī)制保證數(shù)據(jù)如果未成功處理,可以及時(shí)發(fā)現(xiàn),并通知Spout重發(fā) 不重:使用msgID去重 NextTuple中, emit時(shí),指定msgID Bolt容錯(cuò) emit時(shí),錨定輸入Tuple ack輸入tuple Trident API 為用戶屏蔽掉一些狀態(tài)與計(jì)算一致的細(xì)節(jié) 使用戶更方便的書寫可容錯(cuò)的作業(yè)查看全部
-
批量計(jì)算與流式計(jì)算的區(qū)別查看全部
-
spout負(fù)責(zé)讀取數(shù)據(jù),下游bolt負(fù)責(zé)讀取數(shù)據(jù)并shuffle,再由下面的bolt寫到data-sink,總體和mr比較像。但因?yàn)槭橇魇接?jì)算,不會(huì)像mr一樣完成之后再輸出結(jié)果,它會(huì)來一個(gè)數(shù)據(jù)就輸出一次。查看全部
-
topology任務(wù)結(jié)構(gòu) -spout數(shù)據(jù)源節(jié)點(diǎn) -bolt普通計(jì)算節(jié)點(diǎn) -stream數(shù)據(jù)流 -tuple記錄查看全部
舉報(bào)
0/150
提交
取消