發(fā)簡信
IP屬地：北京
-
Apache Pulsar 源碼走讀（五）服務端消息流轉邏輯概述
版權歸本人所有，如果轉載請聯系本人 這篇大致說一下消息從寫入到讀取在Apache Pulsar服務端是怎么串起來的。( 這篇不會詳細說明每個邏輯怎么走的，不過會給讀者一個整體...
-
Apache Pulsar 源碼走讀（四）TopicLookup請求處理（二）
上一篇說到實際的核心邏輯是這2行代碼 這里傳遞的參數將loadTopicsInBundle 設置了成true。我們看下在處理lookup請求過程中是否有l(wèi)oadtopic的邏...
-
Apache Pulsar 源碼走讀（三）TopicLookup 請求處理（一）
簡單邏輯說明通過topic名字確定namespace查找這個namespace的bundle分配信息根據bundle分配信息來確認這個topic屬于哪個bundle根據bun...
-
Apache Pulsar 源碼走讀（二）二進制協議pulsar 使用protocolBuf 作為二進制協議編寫的工具 本文主要說明其中幾個主要的RPC 的作用。并大致說一下這個幾個RPC會被使用的位置。具體每個字段的含義會在...
-
Apache Bookkeeper —— SingleDirectoryDBLedgerStorage
主要成員變量 主要作用 可以讀寫ledger，維護ledger的位置（index） 保存ledger相關的metadata 支持checkpoint 寫入Entry 寫入會直...
-
Apache Bookkeeper —— Journal 源碼分析
簡單梳理一下這個類的作用和邏輯。 主要功能 充當WAL 寫請求處理：首先在Bookkeeper服務端收到了寫Entry的請求之后會交給Bookie來處理Bookie.addE...
-
-
本博客所有內容均適用知識共享-署名-相同方式共享（CC-BY-SA）4.0協議。
-
PulsarClient 解析(一）PulsarClient 讓我們看一下這個類的主要方法 創(chuàng)建producer/consumer/reader 元數據信息相關 transaction相關 close方法 Cl...
-
Apache Pulsar 源碼走讀（一）啟動
1.啟動入口 PulsarStandaloneStarter在standalone模式下，主要啟動了以下幾個服務 PulsarService PulsarAdmin Loca...
-
PingCAP 是一家開源的新型分布式數據庫公司，秉承開源是基礎軟件的未來這一理念，PingCAP 持續(xù)擴大社區(qū)影響力，致力于前沿技術領域的創(chuàng)新實現。其研發(fā)的分布式關系型數據庫 TiDB 項目，具備「分布式強一致性事務、在線彈性水平擴展、故障自恢復的高可用、跨數據中心多活」等核心特性，是大數據時代理想的數據庫集群和云數據庫解決方案。目前準生產測試用戶 1000 余家，并已被 200 余家不同行業(yè)的領先企業(yè)應用在實際生產環(huán)境，涉及互聯網、游戲、金融、政府、電信、制造業(yè)等多個領域。（官網：<a href="https://links.jianshu.com/go?to=http%3A%2F%2Fpingcap.com" target="_blank">http://pingcap.com</a> 源碼地址：<a href="https://links.jianshu.com/go?to=http%3A%2F%2Fgithub.com%2Fpingcap" target="_blank">http://github.com/pingcap</a>）
-
FLIP-6 Flink runtime設計文檔摘要（一）這篇主要是組件的職責和功能 每個JobManager負責一個Job，在提交JobGraph時創(chuàng)建，在job完成后銷毀 JobManager同樣可以通過savepoint創(chuàng)建 ...
