Flink SQL在線調(diào)試功能能夠幫助用戶數(shù)據(jù)探索與邏輯校驗(yàn)，調(diào)試功能要求如下： 為了滿足上述要求，我們開發(fā)了基于redis的調(diào)試插件，用該插件替換原sink目標(biāo)，具體步驟如...
發(fā)簡(jiǎn)信
IP屬地：廣東
-
Flink SQL在線調(diào)試功能的實(shí)現(xiàn)
-
Flink SQL多字段的維表關(guān)聯(lián)查詢-flink-connector-redis
Flink SQL經(jīng)常需要關(guān)聯(lián)維表，使用redis作為維表存儲(chǔ)介質(zhì)能獲得較快的響應(yīng)速度，大多情況維表有多個(gè)字段,寫入與維表查詢時(shí)只能使用concat與table functi...
-
flink catalog 之 flink-catalog-in-jdbc
開發(fā)思路 運(yùn)行環(huán)境全面升級(jí)到j(luò)dk11后，原基于hive catalog的flink catlog不能再使用，原因是現(xiàn)在hive所有版本都不支持jdk11,但在大趨勢(shì)下jdk...
-
flink維表查詢r(jià)edis之flink-connector-redis
插件名稱：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connector-redis.git[h...
-
本博客所有內(nèi)容均適用知識(shí)共享-署名-相同方式共享（CC-BY-SA）4.0協(xié)議。
-
mybatis insert后返回主鍵ID實(shí)現(xiàn)原理及源碼分析
引子： mybatis這類ORM在往數(shù)據(jù)庫(kù)insert對(duì)象后，會(huì)順帶將數(shù)據(jù)庫(kù)中的自增主鍵值賦值給對(duì)象的id,這個(gè)功能給我們的開發(fā)帶來(lái)了很多方便，那它是怎么實(shí)現(xiàn)的呢? 源碼分析...
-
W-TinyLFU源碼分析（Caffeine）
Caffeine使用一個(gè)ConcurrencyHashMap來(lái)保存所有數(shù)據(jù)，那它的過(guò)期淘汰策略采用的什么的方式與數(shù)據(jù)結(jié)構(gòu)呢?其中寫過(guò)期是使用writeOrderDeque,這...
-
flink1.12 sql向redis實(shí)時(shí)寫數(shù)據(jù)
插件名稱：flink-connector-redis 插件地址：https://github.com/jeff-zou/flink-connector-redis.git[h...
-
Java NIO——零拷貝什么是零拷貝 WIKI中對(duì)其有如下定義： "Zero-copy" describes computer operations in which the CPU does no...
-
從圖上來(lái)看，sendfile不應(yīng)該是兩次上下切換么？
Java NIO——零拷貝
什么是零拷貝 WIKI中對(duì)其有如下定義： "Zero-copy" describes computer operations in which the CPU does no...
-
如果對(duì)CA機(jī)構(gòu)發(fā)起中間人攻擊，讓瀏覽器里的CA機(jī)構(gòu)公鑰是假的，這個(gè)有可能嗎?
為什么 HTTPS 是安全的？你知道嗎？
都知道 HTTPS 安全，可是為什么安全呢？看小電影還是瀏覽正常網(wǎng)站，一定要檢查是不是 HTTPS 的，HTTP有可能被中間人攻擊和攔截，下面就是詳細(xì)的 HTTPS 原理，幫...
-
go協(xié)程學(xué)習(xí)筆記協(xié)程本質(zhì)： go協(xié)程本質(zhì)上還是用線程來(lái)運(yùn)行代碼，只是在多線程上增加了調(diào)度器，通過(guò)調(diào)度器讓每一個(gè)線程可以執(zhí)行多個(gè)協(xié)程。 實(shí)現(xiàn)原理： go協(xié)程使用GPM調(diào)度模型實(shí)現(xiàn)，具體內(nèi)容如下...
-
FLINK基于SQL向redis更新多維度狀態(tài)（多字段）
在實(shí)時(shí)計(jì)算平臺(tái)接入業(yè)務(wù)過(guò)程中，經(jīng)常遇到這樣一個(gè)問(wèn)題： 第一個(gè)任務(wù)獲得的最新?tīng)顟B(tài)需要提供給后續(xù)一個(gè)或者多個(gè)任務(wù)使用。解決這個(gè)問(wèn)題有很多方法，將狀態(tài)序列化到消息隊(duì)列中或者持久化到...
-
log4j日志落地文件改造-方便以文件形式進(jìn)行日志文件同步
log4j日志落地文件是先寫入到文件名為*.log的文件中，達(dá)到一定條件后重命名，再生成一個(gè)新的空*.log文件，這種方式有一個(gè)弊端就是最新日志內(nèi)容始終在*.log中，很不利...
-
centos7.4/7.5搭建kafka1.1.0消息隊(duì)列集群(使用SASL_PLAINTEXT)
kafka增加了賬號(hào)認(rèn)證后標(biāo)志著它向企業(yè)級(jí)發(fā)展邁出了關(guān)鍵的一步，在這個(gè)功能后kafka也終于有了大版本，到現(xiàn)在已經(jīng)演進(jìn)到1.1.0，發(fā)展迅速以至于國(guó)內(nèi)相關(guān)實(shí)踐的資料很少，或者...
