前言 祝廣大女性節(jié)日快樂~ 快問快答 Flink DataStream API中的RichFunction有哪些用途/特點？RichFunction中獲取到的RuntimeC...
發(fā)簡信
IP屬地：北京
-
Flink RichFunction題目一則 -
圖片加載不出來??
Flink RocksDB托管內(nèi)存機制的幕后——Cache & Write Buffer Manager
前言 為了解決Flink作業(yè)使用RocksDB狀態(tài)后端時的內(nèi)存超用問題，F(xiàn)link早在1.10版本就實現(xiàn)了RocksDB的托管內(nèi)存（managed memory）機制。用戶只...
-
我來了大哥??
Flink 1.10 SQL、HiveCatalog與事件時間整合示例
本文已授權(quán)「Flink中文社區(qū)」微信公眾號發(fā)布并標(biāo)注原創(chuàng)。 前言 Flink 1.10與1.9相比又是個船新版本，在我們感興趣的很多方面都有改進，特別是Flink SQL。本...
-
-
看來已經(jīng)在為東哥賣命了????
淺談Flink對象重用（object reuse）
前言 今天是大年初一，祝各位虎年大吉大利~ 近期受工作變動影響，博客又荒廢了許久。今天難得有空，就前段時間內(nèi)部技術(shù)分享里提到的一個小知識點來寫幾筆。 對象重用（object ...
-
@LittleMagic 那豈不是帶團隊了 手下還缺人么 帶我啊
2021。
2021年的最后幾個小時了，抽空來寫幾筆。待會兒再揭曉年度最佳單曲。 健康 新冠疫情仍然沒有趨緩的跡象。看著近期又開始上漲的確診病例數(shù)，還有承載著不同生活軌跡的流調(diào)報告，有時...
-
@LittleMagic 是不是技術(shù)顧問,已經(jīng)入職了嗎 有沒有一個名字叫l(wèi)ihe的同事
2021。
2021年的最后幾個小時了，抽空來寫幾筆。待會兒再揭曉年度最佳單曲。 健康 新冠疫情仍然沒有趨緩的跡象?？粗谟珠_始上漲的確診病例數(shù)，還有承載著不同生活軌跡的流調(diào)報告，有時...
-
大哥來頭條了嗎??
2021。
2021年的最后幾個小時了，抽空來寫幾筆。待會兒再揭曉年度最佳單曲。 健康 新冠疫情仍然沒有趨緩的跡象?？粗谟珠_始上漲的確診病例數(shù)，還有承載著不同生活軌跡的流調(diào)報告，有時...
-
@LittleMagic 老大 還等著你那招人呢 什么時候有信??
From Calcite to Tampering with Flink SQL
今天為組內(nèi)同學(xué)做了題為「From Calcite to Tampering with Flink SQL」的分享，將Markdown版講義貼在下面。 本次分享信息量極大，涵蓋...
-
@LittleMagic ??等你好消息
From Calcite to Tampering with Flink SQL
今天為組內(nèi)同學(xué)做了題為「From Calcite to Tampering with Flink SQL」的分享，將Markdown版講義貼在下面。 本次分享信息量極大，涵蓋...
-
無縫更改ClickHouse物化視圖SELECT邏輯的方法累成狗的一天，繼續(xù)超短文模式。 在我司的ClickHouse DWS層有一張ReplicatedAggregatingMergeTree引擎的物化視圖，為近線推薦業(yè)務(wù)提供關(guān)鍵...
-
From Calcite to Tampering with Flink SQL今天為組內(nèi)同學(xué)做了題為「From Calcite to Tampering with Flink SQL」的分享，將Markdown版講義貼在下面。 本次分享信息量極大，涵蓋...
-
spark的codegen源碼大佬能給講講么
From Calcite to Tampering with Flink SQL
今天為組內(nèi)同學(xué)做了題為「From Calcite to Tampering with Flink SQL」的分享，將Markdown版講義貼在下面。 本次分享信息量極大，涵蓋...
-
大哥你們是不是要被合并到阿里了??
「I believe what you said」
時隔三個月之后的第一首歌詞，當(dāng)然要搞搞事情了（ 2020年10月動畫《寒蟬泣之時 業(yè)》（ひぐらしのく頃に 業(yè)）片頭曲 https://y.qq.com/n/ryqq/song...
-
打造MacOS版“XShell”1.背景 XShell作為一個強大的安全終端模擬軟件，它支持SSH1, SSH2, 以及Microsoft Windows 平臺的TELNET 協(xié)議。作為server端開發(fā)，...
-
HIVE UDTF 自定義函數(shù)
HIVE UDTF 自定義函數(shù) 關(guān)鍵詞：HIVE UDTF 開發(fā) 實例Hive運行用戶自定義函數(shù)對數(shù)據(jù)信息處理，可以試用show functions查看 hive當(dāng)前支持的...
-
說點什么吧
「ピンクレモネード」（粉色檸檬水）
三月都快要過去了，怎么能不來一首「三月的幻想」的歌呢hhh 2018年10月動畫《只要貝爾哲布布大小姐喜歡就好?！菲^曲https://y.qq.com/n/yqq/song...
-
Flink SQL流式聚合Mini-Batch優(yōu)化原理淺析前言 流式聚合（streaming aggregation）是我們編寫實時業(yè)務(wù)邏輯時非常常見的場景，當(dāng)然也比較容易出現(xiàn)各種各樣的性能問題。Flink SQL使得用戶可以通過簡...
-
（跳躍）一致性哈希及其在Greenplum中的應(yīng)用前言 一致性哈希（consistent hashing）是分布式系統(tǒng)中非常重要的算法，在平滑擴縮容、動態(tài)負(fù)載均衡等方向有大量應(yīng)用。相對于傳統(tǒng)的線性（取模）哈希算法，一致性哈希...
-
來了來了??
實戰(zhàn)自定義Flink SQL Connector（w/ Flink 1.11 & Redis）
Foreword Flink SQL之所以簡潔易用而功能強大，其中一個重要因素就是其擁有豐富的Connector（連接器）組件。Connector是Flink與外部系統(tǒng)交互的...