IP屬地：四川
-
Flink 狀態(tài)管理 (Working with State)
說(shuō)到狀態(tài)管理, 必須要提一下 checkpoint, Flink 中每個(gè)函數(shù)和算子都可以是有狀態(tài)的, 有狀態(tài)的函數(shù)需要存儲(chǔ)每個(gè)事件的處理過(guò)程數(shù)據(jù)...
-
有趣的Scala
First Steps to Scala，Scala 入門(mén)教程。 A Scala Tutorial，一篇面向 Java 程序員的 Scala 教...
-
Flink編程<二> Windowing
對(duì)于非清洗數(shù)據(jù)類(lèi)的任務(wù), 時(shí)間窗口的使用是很有必要的. 和spark不同, 需要時(shí)刻謹(jǐn)記, 這是一個(gè)流, 這是一個(gè)流, 這是一個(gè)流.
-
Flink編程<三> 坑
1 注意import的StreamExecutionEnvironment // java 的頭是 import org.apache.flin...
-
Flink編程<一> 概念, Setup首先需要編程應(yīng)用的四層抽象: 最底下的一層對(duì)用戶(hù)是不可見(jiàn)的, 通過(guò)ProcessFunction集成到DataStream API. 我們的編程...
-
決策樹(shù)
Decision Tree (決策樹(shù)/判定樹(shù))是監(jiān)督學(xué)習(xí)中的分類(lèi)算法, 通常預(yù)測(cè)和分類(lèi)算法的評(píng)估主要體現(xiàn)在: 準(zhǔn)確率：預(yù)測(cè)的準(zhǔn)確與否是本算法的核...
-
Flink計(jì)算架構(gòu)簡(jiǎn)析在談Flink之前, 我們?cè)谝粋€(gè)更高的層面上來(lái)理解一下數(shù)據(jù)的處理, 包括數(shù)據(jù)類(lèi)型和處理模型兩個(gè)大的方面. 首先, 是數(shù)據(jù)的類(lèi)型 我們把數(shù)據(jù)處理分...
-
ES - 中文分詞及高亮搜索包括內(nèi)容: IK分詞組件的添加和配置 索引建立及高亮搜索示例 添加自定義分詞的測(cè)試 版本: ES - 2.4.5, IK - 1.10.5ps:...
-
ES - 集群點(diǎn)滴
這里主要記錄一下集群使用用碰到過(guò)的要點(diǎn), 以及對(duì)性能優(yōu)化比較有意義的知識(shí)點(diǎn). 會(huì)逐漸完善拆解 內(nèi)存: 首先應(yīng)該記住, 必須給予Elasticse...