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