前言 祝廣大女性節(jié)日快樂~ 快問快答 Flink DataStream API中的RichFunction有哪些用途/特點(diǎn)？RichFunction中獲取到的RuntimeC...
發(fā)簡信
IP屬地：北京
-
Flink RichFunction題目一則 -
無縫更改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版講義貼在下面。 本次分享信息量極大，涵蓋...
-
打造MacOS版“XShell”1.背景 XShell作為一個強(qiáng)大的安全終端模擬軟件，它支持SSH1, SSH2, 以及Microsoft Windows 平臺的TELNET 協(xié)議。作為server端開發(fā)，...
-
spark讀取parquet文件優(yōu)化
業(yè)務(wù)背景 Spark讀取文件時，對于可切分的文件，會將文件切分為一系列 Split ，每個Split對應(yīng)一個Task。一般而言，Split的大小與HDFS的Block大小相當(dāng)...
-
HIVE UDTF 自定義函數(shù)
HIVE UDTF 自定義函數(shù) 關(guān)鍵詞：HIVE UDTF 開發(fā) 實(shí)例Hive運(yùn)行用戶自定義函數(shù)對數(shù)據(jù)信息處理，可以試用show functions查看 hive當(dāng)前支持的...
-
Flink SQL流式聚合Mini-Batch優(yōu)化原理淺析前言 流式聚合（streaming aggregation）是我們編寫實(shí)時業(yè)務(wù)邏輯時非常常見的場景，當(dāng)然也比較容易出現(xiàn)各種各樣的性能問題。Flink SQL使得用戶可以通過簡...
-
（跳躍）一致性哈希及其在Greenplum中的應(yīng)用前言 一致性哈希（consistent hashing）是分布式系統(tǒng)中非常重要的算法，在平滑擴(kuò)縮容、動態(tài)負(fù)載均衡等方向有大量應(yīng)用。相對于傳統(tǒng)的線性（取模）哈希算法，一致性哈希...
-
實(shí)戰(zhàn)自定義Flink SQL Connector（w/ Flink 1.11 & Redis）Foreword Flink SQL之所以簡潔易用而功能強(qiáng)大，其中一個重要因素就是其擁有豐富的Connector（連接器）組件。Connector是Flink與外部系統(tǒng)交互的...
