本篇內容主要講解“spark streaming中ratecontroller是什么”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“spark streaming中ratecontroller是什么”吧!
spark streaming中采用的模型如下，基本思想是按照100ms的批次發送數據給controller，剛開始controller直接轉給jobgenerator，jobgenerator在生成job，交給jobprocessor來處理，jobprocessor將job統計信息發送給controller，controller接收到統計信息，會動態改變batch size來給job發送數據。
ratecontroller的子類有receiverratecontroller、directkafkaratecontroller。
receiverratecontroller會向receivertracker發送updatereceiverratelimit消息。
receivertracker接收到updatereceiverratelimit消息后，向receiversupervisorimpl轉發updateratelimit消息。
receiversupervisorimpl接收到updateratelimit消息后，調用blockgenerator的updaterate方法，來控制數據的接收速度。
blockgenerator繼承自ratelimiter。
到此，相信大家對“spark streaming中ratecontroller是什么”有了更深的了解，不妨來實際操作一番吧！這里是箭頭云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！

手機域名是什么后綴？為什么注冊手機域名？
公司變更流程-其他問題
一共有多少2個字母域名？2個字母域名有多少個
百度云服務器怎么設置安全問題
php如何取出字符串中的最后幾個字符
美橙云服務器多少錢
我注冊的域名為什么顯示注冊失敗
阿里云服務器ecs這么買才優惠