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