JStorm基礎問題

  • 若bolt的并發(fā)度為N(N > 1),則會有N個task來執(zhí)行此component。那這些task是公用一個bolt實例,還是為每個task都創(chuàng)建一個bolt實例呢?
    答:從Task的創(chuàng)建過來看,每個task都會創(chuàng)建自己的bolt實例。
    com.alibaba.jstorm.task.Task
public Task(WorkerData workerData, int taskId) throws Exception {
    ...
    this.taskObj = Common.get_task_object(
                    topologyContext.getRawTopology(), componentId, WorkerClassLoader.getInstance());
    ...
}

com.alibaba.jstorm.cluster.Common

public static Object get_task_object(StormTopology topology, String component_id, URLClassLoader loader) {
        ...
        Object rtn;
        if (componentObject instanceof JavaObject) {
            rtn = Thrift.instantiateJavaObject((JavaObject) componentObject);
        }
       ...
       return rtn;
} 
  • 延時調(diào)度 / 窗口式調(diào)度 / 節(jié)拍式調(diào)度:若期望bolt的執(zhí)行具有下列特點,可使用storm的定時任務來完成
    • bolt每次執(zhí)行要有時間間隔
    • bolt微批量消費數(shù)據(jù)
    • 高頻冪等
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關(guān)閱讀更多精彩內(nèi)容

  • 目錄 場景假設 調(diào)優(yōu)步驟和方法 Storm 的部分特性 Storm 并行度 Storm 消息機制 Storm UI...
    mtide閱讀 17,279評論 30 60
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務發(fā)現(xiàn),斷路器,智...
    卡卡羅2017閱讀 136,545評論 19 139
  • [一] 李健又回到歌手的舞臺了,好朋友說,看到譚晶退賽,她都想棄了這節(jié)目,可是,健哥男神回來了,她又有了看的理由。...
    若昭閱讀 791評論 1 2
  • 原型對象 Javascript,萬事萬物皆對象;但是呢,對象也是有區(qū)別滴,它分為普通對象和函數(shù)對象;也就是obje...
    AnnQi閱讀 428評論 0 0
  • 在正念的奇跡,這本書中,講了兩個故事,我覺得很有啟發(fā)。一個是洗碗?,F(xiàn)在晚上下班后我要做飯,吃完飯后需要洗碗,有時自...
    LilyZheng閱讀 288評論 0 1

友情鏈接更多精彩內(nèi)容