Topology
一個topology 是 spouts 和 bolts 組成的圖溉奕,通過stream groupings 將圖中的spouts和bolts連接起來茬斧。
拓?fù)浣Y(jié)構(gòu)示意圖
Stream
stream塔拳,消息流吁伺。一個消息流是一個沒有邊界的tuple序列涛酗,而這些tuple序列會以一種分布的方式進行創(chuàng)建和處理陌兑。
tuple的類型可以為:integer沈跨,short,byte兔综,string饿凛,double,float软驰,boolean涧窒,byte array 或者自定義(需要手動實現(xiàn)序列化器)同時實現(xiàn)spouts 和 blots 的接口來處理stream和業(yè)務(wù)邏輯
Spout
spouts是stream消息流中消息的生產(chǎn)者。一般是通過在外部讀入數(shù)據(jù)并且向topo中發(fā)送tuple锭亏。
Bolts
bolts負(fù)責(zé)對消息進行處理纠吴,如過濾,聚合慧瘤,查詢數(shù)據(jù)庫等