發(fā)簡(jiǎn)信
IP屬地：寧夏
-
快速排序
背景 看了網(wǎng)上很多博客的快速排序其實(shí)是錯(cuò)誤的那槽，例子跑的通，但是遇到一些特殊情況鳞芙，排序就失效了，花了一點(diǎn)時(shí)間研究了下，以文本記錄下了原朝，順便沉淀下驯嘱。...
-
Flink SQL UDF 實(shí)現(xiàn) Demo
Flink 包含3種UDF函數(shù) 1、Scalar Functions 標(biāo)量函數(shù) 標(biāo)量函數(shù)喳坠，是指返回一個(gè)值的函數(shù)鞠评。標(biāo)量函數(shù)是實(shí)現(xiàn)將0，1壕鹉，或者多個(gè)...
-
開sasl的kafka測(cè)試環(huán)境搭建
背景 最近有業(yè)務(wù)方提出來生產(chǎn)的kafka的數(shù)據(jù)需要同步到測(cè)試kafka剃幌，因?yàn)樯a(chǎn)kafka集群開了sasl認(rèn)證，為了保證環(huán)境一致晾浴，測(cè)試kafka...
-
基于ambari hadoop平臺(tái)的搭建環(huán)境準(zhǔn)備 1:jdk安裝,防止在/opt/data下,tar –zxf 安裝包在/opt/apps下 所有節(jié)點(diǎn)都需要 2:sudo apt up...
-
內(nèi)存模型
flink的內(nèi)存模型和其他流式計(jì)算框架的內(nèi)存模型有所不同负乡。為了減少OOM的發(fā)生，flink提供了一種off-heap模式充分利用了direct...
-
checkpoint深入理解基本概念 1.產(chǎn)生的背景 在經(jīng)歷storm和spark的洗禮之后脊凰，首個(gè)stateful的流式計(jì)算引擎Apache Flink 應(yīng)運(yùn)而...