課程介紹:
Storm是一個分布式的,可靠的,容錯的數(shù)據(jù)流處理系統(tǒng)。Storm集群的輸入流由一個被稱作spout的組件管理,spout把數(shù)據(jù)傳遞給bolt, bolt要么把數(shù)據(jù)保存到某種存儲器,要么把數(shù)據(jù)傳遞給其它的bolt。一個Storm集群就是在一連串的bolt之間轉(zhuǎn)換spout傳過來的數(shù)據(jù)。
Storm組件
在Storm集群中,有兩類節(jié)點:主節(jié)點master node和工作節(jié)點worker nodes。主節(jié)點運行Nimbus守護(hù)進(jìn)程,這個守護(hù)進(jìn)程負(fù)責(zé)在集群中分發(fā)代碼,為工作節(jié)點分配任務(wù),并監(jiān)控故障。Supervisor守護(hù)進(jìn)程作為拓?fù)涞囊徊糠诌\行在工作節(jié)點上。一個Storm拓?fù)浣Y(jié)構(gòu)在不同的機(jī)器上運行著眾多的工作節(jié)點。每個工作節(jié)點都是topology中一個子集的實現(xiàn)。而Nimbus和Supervisor之間的協(xié)調(diào)則通過Zookeeper系統(tǒng)或者集群。
——————-課程目錄——————-
│ ├Storm第01天-01.介紹與安裝.mp4
│ ├Storm第01天-02.storm配置-啟動進(jìn)程.mp4
│ ├Storm第01天-03.storm體驗Spout-bolt編程.avi
│ ├Storm第02天-01.StormZK考查-NC集成log輸出.avi
│ ├Storm第02天-02.Spout進(jìn)程考查-并發(fā)度.avi
│ ├Storm第02天-03.Spout分組策略-shuffle-all-field-direct.avi
│ ├Storm第02天-04.Spout可靠消息的保證-ack-fail-callback.avi
│ ├Storm第02天-05.Spout超時設(shè)置.avi
│ ├Storm第03天-01.Storm并發(fā)度設(shè)置.avi
│ ├Storm第03天-02.Storm再平衡-ncbug糾錯.avi
│ ├Storm第03天-03.Storm基礎(chǔ)kafka.avi
│ ├Storm第03天-04.Storm基集成kafka-bug修正.avi
│ ├Storm第03天-05.Storm Trident.avi
│ ├Storm第04天-01.Trident批次原理考查-分區(qū)展示.avi
│ ├Storm第04天-02.聚合函數(shù).avi
│ ├Storm第04天-03.自定義聚合函數(shù)-Sum-SumAsAggregator.avi
│ ├Storm第04天-04.自定義聚合函數(shù)-Sum-CombinerAggregator.avi
│ ├Storm第04天-05.Drpc-topology值獲取.avi
│ ├Storm第05天-01.hbase-storm集成.avi
│ └Storm第05天-01.hbase-storm集成2.avi