JStorm和DRPC

DRPC 客戶端將要執行的函數名以及相應的參數發送給DRPC server 。實現了這個函數的topology使用 DRPCSpout來接收從DRPC server傳來的函數的遠程調用流,從而來執行該函數。每一次函數的遠程調用都被DRPC server附上了一個唯一的id。接下來topology計算結果,在最後topology中的bolt調用ReturnResults來連接DRPC server並
相關文章
相關標籤/搜索