發(fā)簡(jiǎn)信
IP屬地：北京
-
今天，你“羊”了嗎？“ 一切都會(huì)過(guò)去！除了羊的第二關(guān)....” 今天，你“羊”了嗎？這應(yīng)該是最近出現(xiàn)頻次最多的用語(yǔ)了吧！“羊了個(gè)羊”是最近非?；鸨囊豢钗⑿判∮螒颉?..
-
Flink 源碼筆記 — execute 后發(fā)生了什么？
前言 我們知道，F(xiàn)link 程序的執(zhí)行是在我們調(diào)用 env.execute() 后才會(huì)真正開(kāi)始。事實(shí)上，我們?cè)诰帉?xiě)業(yè)務(wù)代碼時(shí)，是在勾勒程序執(zhí)行的...
-
flink 學(xué)習(xí)筆記 — 基于 Flink 實(shí)時(shí)數(shù)倉(cāng)的簡(jiǎn)單實(shí)踐回顧 Flink 因其高吞吐、低延時(shí)、有狀態(tài)、高容錯(cuò)的特性越來(lái)越受到數(shù)據(jù)從業(yè)者的青睞，它彌補(bǔ)了Storm、Spark 的很多不足。作為一個(gè)實(shí)時(shí)計(jì)...
-
flink 學(xué)習(xí)筆記 — 狀態(tài) State回顧 在之前的學(xué)習(xí)中我們了解到，flink 作為低延時(shí)的流式數(shù)據(jù)處理框架，本身是有狀態(tài)的。狀態(tài) state 是為了保存一些操作符 operato...
-
簡(jiǎn)單說(shuō)說(shuō)數(shù)據(jù)倉(cāng)庫(kù)數(shù)據(jù)倉(cāng)庫(kù)介紹 數(shù)據(jù)倉(cāng)庫(kù)是集成的、面向主題的、反應(yīng)歷史的數(shù)據(jù)的集合。它需要具有高效查詢(xún)、高質(zhì)量的、可擴(kuò)展的的特性。數(shù)據(jù)倉(cāng)庫(kù)是協(xié)助運(yùn)營(yíng)及管理人員及時(shí)...
-
flink 學(xué)習(xí)筆記 — 時(shí)間定義及窗口機(jī)制flink 回顧 通過(guò)之前的了解，我們知道，flink是一個(gè)高吞吐、低延時(shí)的流式處理框架。flink 中具有嚴(yán)格的時(shí)間定義，采用不同的時(shí)間機(jī)制，...
-
flink 學(xué)習(xí)筆記 — 編程模型flink 抽象分層結(jié)構(gòu) flink 作為流式處理框架，不僅具有高效的流數(shù)據(jù)和批數(shù)據(jù)處理性能，具有針對(duì)開(kāi)發(fā)人員使用的高效的底層API，同時(shí)有方便...
-
flink 學(xué)習(xí)筆記 — 初識(shí) flinkApache flink 簡(jiǎn)介 Apache flink 是分布式流式數(shù)據(jù)處理框架，主要用于有界(bounded)和無(wú)界(unbounded)數(shù)...
-
flink 學(xué)習(xí)筆記 — 自定義 Sink 函數(shù)
flink Sink簡(jiǎn)介 flink 中有兩個(gè)重要的概念，Source 和 Sink ，Source 決定了我們的數(shù)據(jù)從哪里產(chǎn)生，而 Sink ...